Java - 如何告诉所有子线程已完成

Question

我想同时运行一些任务,所以我有一个代码如下:

for(final Task task : tasks){
    (new Thread(){public void run(){
        task.run(args);
}}).start();

我怎么知道所有任务何时完成(任务量可以变化),以便我可以在完成所有任务后运行某些东西？

System.out.println("All tasks are finished");

Answer 1

而不是显式创建Threads,将Runnables提交给ExecutorService,然后调用其shutdown和awaitTermination方法:

ExecutorService executor = Executors.newFixedThreadPool(tasks.size());

for (final Task task : tasks) {
    executor.submit(new Runnable() {
        @Override
        public void run() {
            task.run(args);
        }
    });
}

executor.shutdown();
executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLSECONDS);

Answer 2

较短的版本是使用parallelStream

tasks.parallelStream().forEach(t -> t.run(args));

这将使用您拥有的所有CPU(如果您有足够的任务)运行所有任务,并等待全部完成.