BlockingQueue接口及ArrayBlockingQueue实现类的方法
导读：本文共3970.5字符，通常情况下阅读需要13分钟。同时您也可以点击右侧朗读，来听本文内容。按键盘←（左） →（右） 方向键可以翻页。
摘要： 队列是一种 FIFO（先进先出）的数据结构，本文要讲的 BlockingQueue 也是一种队列，而且强调了线程安全的特性。BlockingQueue全称：java.util.concurrent.BlockingQueue。它是是一个线程安全的队列接口，多个线程能够以并发的方式从队列中插入数据，取出数据的同时不会出现线程安全的问题。生产者和消费者例子Block... ...
目录
(为您整理了一些要点),点击可以直达。
队列是一种 FIFO（先进先出）的数据结构，本文要讲的 BlockingQueue 也是一种队列，而且强调了线程安全的特性。
BlockingQueue全称：java.util.concurrent.BlockingQueue。它是是一个线程安全的队列接口，多个线程能够以并发的方式从队列中插入数据，取出数据的同时不会出现线程安全的问题。
BlockingQueue 通常用于消费者线程向队列存入数据，消费者线程从队列中取出数据，具体如下
生产者线程不停的向队列中插入数据，直到队列满了，生产者线程被阻塞
消费者线程不停的从队列中取出数据，直到队列为空，消费者线程被阻塞
(推荐教程：Java教程）
BlockingQueue 提供 4 种不同类型的方法用于插入数，取出数据以及检查数据，具体如下
操作失败，抛出异常
无论成功/失败，立即返回 true/false
如果队列为空/满，阻塞当前线程
如果队列为空/满，阻塞当前线程并有超时机制插入add(o) offer(o) put(o) offer(o, timeout, timeunit)取出remove(o) poll() take() poll(timeout, timeunit)检查element() peek()
BlockingQueue 只是一个接口，在实际开发中有如下的类实现了该接口。
ArrayBlockingQueue
DelayQueue
LinkedBlockingQueue
PriorityBlockingQueue
SynchronousQueue
这里以 BlockingQueue 接口的具体实现类 ArrayBlockingQueue 举例。通过 ArrayBlockingQueue实现一个消费者和生产者多线程模型。
核心内容如下：
以 ArrayBlockingQueue 作为生产者和消费者的数据容器
通过 ExecutorService 启动 3 个线程，2 两个生产者，1 个消费者
指定数据总量
ArrayBlockingQueueProducer
ArrayBlockingQueueConsumer
测试TestBlockingQueue
输出如下：
BlockingQueue接口及ArrayBlockingQueue实现类的方法的详细内容，希望对您有所帮助，信息来源于网络。