等待ExecutorService所有任务完成的最简单方法是什么?我的任务主要是计算性的，所以我只想运行大量的作业——每个核心上都有一个。现在我的设置是这样的:
ExecutorService es = Executors.newFixedThreadPool(2);
for (DataTable singleTable : uniquePhrases) {
es.execute(new ComputeDTask(singleTable));
}
try{
es.wait();
}
catch (InterruptedException e){
e.printStackTrace();
}
ComputeDTask实现了runnable。这似乎正确地执行了任务，但代码在wait()时崩溃，并出现IllegalMonitorStateException。这是奇怪的，因为我玩了一些玩具的例子，它似乎工作。
uniquePhrases包含数万个元素。我应该用另一种方法吗?我在寻找一些尽可能简单的东西
当前回答
只使用
latch = new CountDownLatch(noThreads)
在每个线程中
latch.countDown();
作为屏障
latch.await();
其他回答
如果您的目标不是等待ExecutorService中的所有任务完成，而是等待特定批次的任务完成，那么您可以使用CompletionService——具体地说，ExecutorCompletionService。
其思想是创建一个包装Executor的ExecutorCompletionService，通过CompletionService提交一些已知数量的任务，然后使用take()(阻塞)或poll()(不阻塞)从完成队列中提取相同数量的结果。一旦绘制了与提交的任务相对应的所有预期结果，就知道它们都完成了。
让我再说一遍，因为从接口上看不太明显:你必须知道有多少东西放入CompletionService，才能知道有多少东西要取出来。这对take()方法尤其重要:调用它一次太多次，它将阻塞您的调用线程，直到其他线程向同一CompletionService提交另一个作业。
在《Java并发实践》一书中有一些例子展示了如何使用CompletionService。
听起来好像你需要ForkJoinPool并使用全局池来执行任务。
public static void main(String[] args) {
// the default `commonPool` should be sufficient for many cases.
ForkJoinPool pool = ForkJoinPool.commonPool();
// The root of your task that may spawn other tasks.
// Make sure it submits the additional tasks to the same executor that it is in.
Runnable rootTask = new YourTask(pool);
pool.execute(rootTask);
pool.awaitQuiescence(...);
// that's it.
}
美在泳池里。awaitQuiescence方法将阻塞利用调用者的线程来执行它的任务，然后当它真的为空时返回。
一个简单的替代方法是使用线程和join。 参考:连接线程
我还有一种情况，我有一组文档要爬取。我从一个应该被处理的初始“种子”文档开始，该文档包含到其他也应该被处理的文档的链接，等等。
在我的主程序中，我只想写如下所示的东西，其中Crawler控制了一堆线程。
Crawler c = new Crawler();
c.schedule(seedDocument);
c.waitUntilCompletion()
如果我想在一棵树上导航，同样的情况也会发生;我将插入根节点，每个节点的处理器将根据需要向队列中添加子节点，一堆线程将处理树中的所有节点，直到没有更多的节点为止。
我在JVM中找不到任何东西，我觉得这有点令人惊讶。所以我写了一个类ThreadPool，一个可以直接使用或子类添加适合域的方法，例如schedule(Document)。希望能有所帮助!
ThreadPool Javadoc | Maven
如果您希望等待所有任务完成，请使用关机方法而不是等待。然后在后面加上awaitterminate。
此外，您还可以使用Runtime。availableProcessors来获取硬件线程的数量，以便正确地初始化线程池。
