8.1 什么是阻塞队列

阻塞队列(BlockingQueue)是一个支持两个附加操作的队列。这两个附加的操作是:在队列为空时,获取元素的线程会等待队列变为非空。当队列满时,存储元素的线程会等待队列可用。

阻塞队列常用于生产者和消费者的场景,生产者是往队列里添加元素的线程,消费者是从队列里拿元素的线程。阻塞队列就是生产者存放元素的容器,而消费者也只从容器里拿元素。

我们不用关心什么时候需要阻塞线程,什么时候需要释放线程,因为这些都会被阻塞队列自动完成。

8.2 阻塞队列的分类

1、 ArrayBlockingQueue;

基于数组的阻塞队列实现,在ArrayBlockingQueue内部,维护了一个定长数组,以便缓存队列中的数据对象。

这是一个常用的阻塞队列,除了维护一个定长数组外,还维护了两个整型常量,分别标识队列的头部和尾部在数组中的位置。

由数组组成的有界阻塞队列。

2、 LinkedBlockingQueue;

基于链表的阻塞队列实现,在LinkedBlockingQueue中,维护了一个链表,如果没有指定链表长度,则默认为Integer.MAX_VALUE。

由链表组成的有界阻塞队列。

3、 DelayQueue;

在DelayQueue中,只有指定的延时时间到了,才能从队列中获取元素。DelayQueue是一个没有大小限制的队列,所以生产者可以一直往里添加元素,而消费者在队列为空的情况下,会发生阻塞。

使用优先级队列实现的延迟无界阻塞队列。

4、 SynchronousQueue;

是一个无缓冲的等待队列,在某次添加元素后必须等待其他线程取走后才能继续添加;可以认为SynchronousQueue是一个缓存值为1的阻塞队列,只存储单个元素。

8.3 阻塞队列核心方法

 

8.4 代码演示

package queue;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;

public class BlockingQueueDemo {

    public static void main(String[] args) throws InterruptedException {
        //创建阻塞队列
        BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);

//        //第一组
//        System.out.println(blockingQueue.add("chen"));
//        System.out.println(blockingQueue.add("xin"));
//        System.out.println(blockingQueue.add("123"));
//        System.out.println(blockingQueue.element());
//        //添加不进去时就报异常
//        //System.out.println(blockingQueue.add("12"));
//
//        System.out.println(blockingQueue.remove());
//        System.out.println(blockingQueue.remove());
//        System.out.println(blockingQueue.remove());
//        //没有元素可删时,就报异常
//        System.out.println(blockingQueue.remove());

//        //第二组
//        System.out.println(blockingQueue.offer("haha"));
//        System.out.println(blockingQueue.offer("heihei"));
//        System.out.println(blockingQueue.offer("yeye"));
//        System.out.println(blockingQueue.offer("dsfa"));  //插入不进去,返回false
//
//        System.out.println(blockingQueue.poll());
//        System.out.println(blockingQueue.poll());
//        System.out.println(blockingQueue.poll());
//        System.out.println(blockingQueue.poll());  //没有值可以出来了,就返回null

//        //第三组
//        blockingQueue.put("adf");
//        blockingQueue.put("asd");
//        blockingQueue.put("qwe");
        blockingQueue.put("sdfa");  //运行到这里就阻塞了
//
//        blockingQueue.take();
//        blockingQueue.take();
//        blockingQueue.take();
//        blockingQueue.take();  //到这里也阻塞了

        //第四组
        System.out.println(blockingQueue.offer("a"));
        System.out.println(blockingQueue.offer("b"));
        System.out.println(blockingQueue.offer("c", 3L, TimeUnit.SECONDS));
        System.out.println(blockingQueue.offer("d", 3L, TimeUnit.SECONDS));  //队列满时会阻塞一段时间,poll用法类似
    }
}