如何检查 ExecutorService 上的所有任务运行是否已完成

Question

我有 ConcurrentLinkedDeque 用于同步 push/pop 元素，我有一些异步任务，它们从堆栈中取出一个元素，如果这个元素有邻居，它就会把它推到堆栈中。

示例代码：

private ConcurrentLinkedDeque<Item> stack = new ConcurrentLinkedDeque<>();
private ExecutorService exec = Executors.newFixedThreadPool(5);

    while ((item = stack.pollFirst()) != null) {
                if (item == null) {
                } else {
                    Runnable worker = new Solider(this, item);
                    exec.execute(worker);
                }
            }

   class Solider{
         public void run(){
             if(item.hasNeighbors){
                for(Item item:item.neighbors){
                    stack.push(item)
                }
             } 
         }
    }

我想在 while 循环中有额外的语句来回答问题 - "any task in Executor is working?"

Answer 1

如果您使用 ExecutorService.execute(Runnable)，则没有一种干净的方法来检查是否所有 Runnable 都已完成。除非你在 Runnable 本身中建立一个机制来这样做（在我看来这很草率）。

改为：
使用 ExecutorService.submit(Runnable)。此方法将 return 一个 Future<?>，它是 Runnable 结果的句柄。使用 Futures 提供了一种检查结果的简洁方法。

您所要做的就是维护您提交的 Futures 列表，然后您可以遍历整个 Futures 列表，并且：
A）等待所有期货以阻塞方式完成或
B) 检查所有的期货是否以非阻塞方式完成。

这是一个代码示例：

List<Future<?>> futures = new ArrayList<Future<?>>();
ExecutorService exec = Executors.newFixedThreadPool(5);

// Instead of using exec.execute() use exec.submit()
// because it returns a monitorable future
while((item = stack.pollFirst()) != null){
    Runnable worker = new Solider(this, item);
    Future<?> f = exec.submit(worker);
    futures.add(f);
}

// A) Await all runnables to be done (blocking)
for(Future<?> future : futures)
    future.get(); // get will block until the future is done

// B) Check if all runnables are done (non-blocking)
boolean allDone = true;
for(Future<?> future : futures){
    allDone &= future.isDone(); // check if future is done
}

Answer 2

更新：使用 Java 8+ CompletableFutures，您可以使用其新的回调函数来管理它。首先，您需要创建所有您需要的 CompletableFutures，它们也将开始运行，例如：

我们需要将所有生成的 futures 累积到一个数组中，以便稍后将它们传递给 CompletableFuture.allOf(CompletableFutures...)

假设您有一个人员列表，您想要异步计算其生日前的天数：

首先我们创建所有需要的 futures 并将它们收集到一个数组中：

CompletableFuture<?>[] completables = people.stream()
    .map(p -> createCompletableFuture(p))
    .toArray(CompletableFuture<?>[]::new);

private CompletableFuture createCompletableFuture(Person p) {
        return CompletableFuture.runAsync(daysUntillBirthday(p));
    }

然后将这些可完成项传递给新的 CompletableFuture：

CompletableFuture c = CompletableFuture.allOf(completables)

你现在可以检查是否还有期货运行:

c.isDone()

如何检查 ExecutorService 上的所有任务运行是否已完成

How to check if all tasks running on ExecutorService are completed

java

multithreading

executorservice

如何检查 ExecutorService 上的所有任务 运行 是否已完成

How to check if all tasks running on ExecutorService are completed

java

multithreading

executorservice

如何检查 ExecutorService 上的所有任务运行是否已完成