如何等待ExecutorService完成而不关闭？

Question

我在ExecutorService中有一些可运行的线程，希望在以下时间后加入线程：

private void foo() {
  //...
  exec.execute(new Runnable(){
    public void run() {
      if (bar()) {
        foo();
      }
    }
  });
}

//exec.shutdown()
//exec.awaitTermination();

因为它在Runnable中调用自己，所以我不能关闭，因为它可能会阻止自己创建新任务。

如何在不关闭的情况下等待所有线程完成？有没有办法返回一个未来，这样我就可以使用未来：：get（）。

Answer 1

Executor.submit（Runnable）将返回一个Future，根据javadoc：

Future的get方法将在成功完成后返回null。

因此，您仍然可以调用future.get（）并阻止它，直到任务完成。

Future<?> future =  exec.submit(new Runnable(){
                                public void run() {
                                       if (bar()) {
                                              foo();
                                       }
                                }
                                });

//blocks
future.get();