多线程池集成

Question

在我的主流程中，我有一个线程池ExecutorService，我用我调用的“已知”数量的可调用项来填充它。

此外，还有另一个ExecutorService对象称为“全球池”（我认为ExecutorService是线程安全的，我可以从不同的线程向其添加任务）。

现在，上面的每个Callable都会产生新的任务，并将它们（提交）到这个共享的“全球池”。

问题是，我无法知道（无法阻止）所有任务何时完成，以及是否没有更多传入的任务。

请协助。

代码段：

public class Worker implements Callable {

        private ExecutorService sharedPool;

        public Worker (ExecutorService pool){
          this.sharedPool = pool;
        }




    public boolean call() {
        for (int i = 0; i<100; i++){
           if(i % 10 == 0){
              sharedPool.submit(new Runnable() {                            
                            public void run() {
                               heavyTaskHere();
                            }
                        }   
           }

        }

    }

}


Main flow:

ExecutorService sharedPool = new Executors.newFixedThreadPool(X);
List<Callable<Boolean>> mainthareadPool=  new ArrayList<Callable<Boolean>>();
ExecutorService executor =  Executors.newFixedThreadPool(N);


for (int i = 0; i<10; i++){
  Wroker w = new Worker (sharedPool);
    mainthareadPool.add(w);
}


executor.invokeAll(mainthareadPool);

在我看来，呼叫者将在他们的可呼叫者结束之前结束。

Answer 1

如果调用所有可调用项，则会返回与可调用项对应的未来列表。有了这个未来，您只需查看您的FutureList.get（futureOfInterestIndex.isOne（）是否已完成可调用项