如何确定线程/任务是否由执行者启动。execute（）（非ExecutorService）已完成？
在Java中，Executor类不像ExecutorService子类那样具有shutdown/shutdownNow（）/awaitTermination。因此，如果通过调用executorObject启动任务/线程。execute（runnableTask），如何检查任务是否完成？
共有1个答案
不能仅仅因为它提供了一个方法void execute（Runnable），就用Executor来实现。除非您考虑使用返回未来的执行器实现，否则您可以实现自己的通知/等待机制：
final CountDownLatch latch = new CountDownLatch(1);
Runnable task = () -> {
try {
// ... do useful work
} finally {
latch.countDown();
}
}
executorObject.execute(task);
// wrap into try/catch for InterruptedException
// if not propagating further
latch.await(); // await(timeout);
-
问题内容： 我有ConcurrentLinkedDeque，它用于同步push / pop元素，还有一些异步任务，这些任务正在从堆栈中获取一个元素，如果该元素具有邻居，则会将其推入堆栈。 示例代码： 我想在while循环中有另外一条语句来回答问题-“执行程序中的任何任务都在工作？” 问题答案： 如果使用，没有一种干净的方法来检查所有Runnable是否都已完成。除非您在Runnable本身中构建了
-
要并行或异步运行一些东西，我可以使用ExecutorService：
-
我正在运行的服务器应用程序获取我要使用任务系统处理的多个任务请求。 每个任务都表示为一个可运行的线程池，该线程池中的线程数小于或等于线程池的大小，需要线程池中的线程数。当然，线程池是必要的，以避免CPU因线程过多而过载。 然而，其中一些任务可以是多线程的，而另一些则不能。这就是为什么一个任务可能需要等待其所有特定线程完成，以便合并这些线程的结果以获得最终结果的原因。 如果使用多个实例，则可以像这样
-
我很难弄清楚我如何知道我的演员何时从非演员代码中完成。 尝试使用akka演员进行并行执行，这似乎真的很好，但我需要知道何时所有人都完成了。 我添加了一个监督者演员，产生演员来做工作，从监督者/父演员，我可以观看孩子的终止消息。 我需要从akka actor系统之外的常规java代码中得到帮助，以确定我的监督actor是否完成。 这是否可能，请提供指针。 谢谢哈瑞
-
我正在用Java编写一个应用程序，它使用ExecutorService来运行多个线程。 我希望将多个任务（一次数千个）作为调用项提交给执行器，完成后，检索它们的结果。我处理这个问题的方式是，每次调用submit（）函数时，都会得到一个Future（未来），并将其存储在ArrayList中。稍后，我将列表传递给一个线程，该线程不断对其进行迭代，调用future.get（）函数并给出一个超时时间，以查