多线程阻塞工作线程

Question

我有4-5个工作线程处理大型消息队列。我还有另一段代码，它使用2-3个worker运行。我想在处理大型消息队列时阻止所有其他工作者。

我正在使用JDK6和Jms

编辑：

队列进程工作者从未终止。当没有消息时，它们阻塞队列。这些工作者由执行器线程池管理，如果我使用读写锁，其中一个工作者也会被阻塞。此外，如果使用循环屏障，那么我必须终止线程，以便重新传递阻塞的第二个进程。由于工作者是由线程池管理的，所以不能保证所有工作者都会忙于处理消息。

让我知道,

final ExecutorService executor = getExecutorManager().getExecutor();
for (int i = 0; i < threadPoolSize; i++) {
executor.submit(new MessageWorker(qConn));
}

final ExecutorService executor = getExecutorManager().getExecutor();
for (int i = 0; i < threadPoolSize; i++) {
executor.submit(new DbUpdateWorker());
}

Answer 1

你需要使用cyclicbarrier。

一种同步辅助，它允许一组线程相互等待到达一个公共屏障点。cyclicbarribares在涉及固定大小的线程组的程序中很有用，这些线程偶尔必须相互等待。该屏障被称为循环的，因为它可以在等待的线程被释放后重新使用。

用作：

CyclicBarrier barrier = new CyclicBarrier(numWorkers, runnable);

其中runnable是要在工作线程完成时调用的runnable。每个线程在完成时调用barrier.await()。