本文中,我们将介绍一个 java.util.concurrent 包提供的用于解决并发生产者 – 消费者问题的最有用的类 BlockQueue。我们将介绍BlockingQueue 接口的 API 以及如何使用该接口的方法使编写并发程序更容易。
在本文的后面,我们将展示一个具有多个生产者线程和多个消费者线程的简单程序的示例。
BlockingQueue 的队列类型
java.util.concurrent 提供了两种类型的 BlockingQueue:
- 无限队列 (unbounded queue ) – 几乎可以无限增长
- 有限队列 ( bounded queue ) – 定义了最大容量
无限队列
创建一个无限队列的方法很简单
BlockingQueue<String> blockingQueue = new LinkedBlockingDeque<
版权声明:本文为jysf98746原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。