Java中在使用Executors线程池时,有时场景需要主线程等各子线程都运行完毕后再执行。这时候就需要用到ExecutorService接口中的awaitTermination方法,我们来看看源码中对该方法的说明:

大概意思是这样的:该方法调用会被阻塞,并且在以下几种情况任意一种发生时都会导致该方法的执行:  即shutdown方法被调用之后,或者参数中定义的timeout时间到达或者当前线程被打断,这几种情况任意一个发生了都会导致该方法在所有任务完成之后才执行。第一个参数是long类型的超时时间,第二个参数可以为该时间指定单位。

比如应用场景为线程池的有效执行时间为20S,20S之后不管子任务有没有执行完毕,都要关闭线程池。代码如下:

	ExecutorService es = Executors.newFixedThreadPool(10);
        es.execute(new Thread());//执行子线程任务
     try {
		es.shutdown();  
		if(!es.awaitTermination(20,TimeUnit.SECONDS)){//20S
		   System.out.println(" 到达指定时间,还有线程没执行完,不再等待,关闭线程池!");
		   es.shutdownNow();  
		}
	} catch (Throwable e) {
		// TODO Auto-generated catch block
		es.shutdownNow();
		e.printStackTrace();
	}


与shutdown()方法结合使用时,尤其要注意的是shutdown()方法必须要在awaitTermination()方法之前调用,该方法才会生效。否则会造成死锁。
 

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐