java - Java线程等待和通知

Question

我有两个线程。线程 A 正在从队列中提取一些元素，线程 B 正在向队列中添加一些元素。

当队列为空时，我希望线程 A 进入睡眠状态。

当线程 B 向队列中添加一些元素时，它应该确保线程 A 正在工作。如何在 Java 中做到这一点？

Answer 1

使用 a BlockingQueue，即：

AQueue还支持在检索元素时等待队列变为非空，并在存储元素时等待队列中可用空间的操作。

说真的，不要试图在这里重新发明轮子。




（如果您必须使用等待/通知，请阅读本教程。但请不要让自己痛苦！）

Answer 2

以下是一些细节：

import java.concurrent.Executors;
import java.concurrent.ExecutorService;
...
ExecutorService executor = Executors.newFixedThreadPool(someNumberOfThreads);
...
executor.execute(someObjectThatImplementsRunnable);
...
executor.shutdownNow();

这就是 Java 更新的线程功能的全部内容。Executor 是一个线程池，其中包含 someNumberOfThreads。它由阻塞队列提供。除非有工作要做，否则所有线程都会休眠。当您使用 execute() 方法将 Runnable 对象推送到队列中时，Runnable 对象将位于队列中，直到有可用的线程来处理它。然后，它的 run() 方法被调用。最后，shutdownNow() 方法通知池中的所有线程关闭。

现在比以前简单多了。

（这有很多变体，例如具有最小和最大线程数的池，或者在调用 execute() 的线程将阻塞之前具有最大大小的队列。）