Java线程等待并通知
我有两个主题。 线程A从队列中提取一些元素,线程B将一些元素添加到队列中。
我希望线程A在队列为空时进入hibernate状态。
当线程B向队列添加一些元素时,应该确保线程A正在工作。 如何在Java中完成?
使用BlockingQueue
,它是:
一个
Queue
,它还支持在检索元素时等待队列变为非空的操作,并在存储元素时等待队列中的空间可用。
说真的,不要试图在这里重新发明轮子。
(如果你必须使用wait / notify,请阅读本教程 。但是请你自己承担痛苦!)
以下是一些细节:
import java.concurrent.Executors; import java.concurrent.ExecutorService; ... ExecutorService executor = Executors.newFixedThreadPool(someNumberOfThreads); ... executor.execute(someObjectThatImplementsRunnable); ... executor.shutdownNow();
这就是Java更新的线程function所需要的。 Executor是一个包含someNumberOfThreads的线程池。 它由阻塞队列提供。 除非有工作要做,否则所有线程都会hibernate。 使用execute()方法将Runnable对象推入队列时,Runnable对象将位于队列中,直到有可用于处理它的线程。 然后,调用run()方法。 最后,shutdownNow()方法通知池中的所有线程都要关闭。
它现在比过去简单得多。
(对此有很多变化,例如具有最小和最大线程数的池,或者在调用execute()的线程阻塞之前具有最大大小的队列。)