我有一个新手的问题.我有这个代码：
public class Main
{
public static void main(String[] args) throws InterruptedException
{
// TODO Auto-generated method stub
IntHolder aHolder=new IntHolder();
aHolder.Number=0;
IncrementorThread A= new IncrementorThread(1,aHolder);
IncrementorThread B= new IncrementorThread(2,aHolder);
IncrementorThread C= new IncrementorThread(3,aHolder);
A.start();
B.start();
C.start();
A.join();
B.join();
C.join();
System.out.println("All threads completed...");
}
}
这将等待所有线程完成.如果我这样使用Executors：
public class Main
{
public static void main(String[] args)
{
// TODO Auto-generated method stub
IntHolder aHolder=new IntHolder();
aHolder.number=0;
IncrementalRunable A= new IncrementalRunable(1,aHolder);
IncrementalRunable B= new IncrementalRunable(2,aHolder);
IncrementalRunable C= new IncrementalRunable(3,aHolder);
ExecutorService exec = Executors.newFixedThreadPool(3);
exec.execute(A);
exec.execute(B);
exec.execute(C);
//Don't know what to do here
System.out.println("All threads completed...");
}
}
如何暂停主线程等待执行器中的所有线程完成,即所有线程完成工作后都应该打印“所有线程完成…”？
解决方法
executor.shutdown();
while (!executor.awaitTermination(24L,TimeUnit.HOURS)) {
System.out.println("Not yet. Still waiting for termination");
}
使用shutdown()awaitTermination()组合.
编辑：
基于@Lital的评论
List<Callable<Object>> calls = new ArrayList<Callable<Object>>(); calls.add(Executors.callable(new IncrementalRunable(1,aHolder))); calls.add(Executors.callable(new IncrementalRunable(2,aHolder))); calls.add(Executors.callable(new IncrementalRunable(3,aHolder))); List<Future<Object>> futures = executor.invokeAll(calls);
注意：所有的任务完成(通过失败或完成成功执行),invokeAll()将不会返回.
