Остановить работу, если все потоки простаивают

Question

У меня есть некоторое количество потребительских потоков, любое из которых также может выступать в качестве производителя. Как я должен знать, когда все они закончили свою работу?

class Worker extends Thread{ 
    void process(Task t){ 
     ... 
     if(needsMoreWork(t)){ 
      queue.addAll(extractTasks(t)); 
     } 
    } 
    public void run(){ 
     while(isRunning){ 
      Task t = queue.take();//I need to finish somehow. 
      process(t); 
     } 
    } 
    ... 
} 

Answer 1

Вместо использования Thread s вручную, представить свои задачи на ExecutorService и использовать CountDownLatch, CyclicBarrier или Phaser синхронизировать их, в зависимости от того, требуется ли многократные циклы вашей работы, и есть ли у вас то же самое количество компонентов задачи в каждом цикле.

В зависимости от того, в чем конкретно состоит ваш process, может быть рассмотрен вопрос: ForkJoinPool; он в основном завершает идею «выполнить эту же операцию над кучей предметов и собрать результаты».