Java ExecutorService：所有递归创建的任务的awaitTermination

如果最初不清楚递归任务树中的任务数量，则最简单的方法可能是实现您自己的同步原语（某种“反信号量”），并在您的任务之间共享它。在提交每个任务之前，您需要增加一个值，当任务完成时，它会减少该值，然后等待直到该值为0。

将其实现为从任务中显式调用的单独原语，可以将此逻辑与线程池实现分离开来，并允许您将多个独立的递归任务树提交到同一池中。

像这样：

public class InverseSemaphore {    private int value = 0;    private Object lock = new Object();    public void beforeSubmit() {        synchronized(lock) { value++;        }    }    public void taskCompleted() {        synchronized(lock) { value--; if (value == 0) lock.notifyAll();        }    }    public void awaitCompletion() throws InterruptedException {        synchronized(lock) { while (value > 0) lock.wait();        }    }}

请注意，

taskCompleted()

finally

还要注意，

beforeSubmit()

编辑： 使用模式已修复的重要问题。