java - 生产者消费者主线程退出，而其他线程正在运行

Question

这个问题已经有答案了:

How to wait for all threads to finish, using ExecutorService? (27 个回答)

已关闭 8 年前。

我的代码片段:

public class ProducerConsumerTest {

  public static void main(String[] args)
  {
    ArrayBlockingQueue<String> sharedQueue = new ArrayBlockingQueue<String>(20, true);

    ExecutorService consumerService = Executors.newFixedThreadPool(5);
    ExecutorService producerService = Executors.newSingleThreadExecutor();

    Future future=producerService.submit(new Producer(sharedQueue));

    consumerService.execute(new Consumer(sharedQueue));
    consumerService.execute(new Consumer(sharedQueue));
    consumerService.execute(new Consumer(sharedQueue));
    consumerService.execute(new Consumer(sharedQueue));
    consumerService.execute(new Consumer(sharedQueue));
  }
}

如何让主线程等待其他线程？

我面临的问题是我不知道 ExecutorService 创建的线程的名称，这就是为什么我不能使用 join() 。例如:t1.join()在main() .

Answer 1

为什么不尝试设置障碍呢？

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/CyclicBarrier.html

PS。我认为它们可以在 JAVA7 及更高版本上运行