1、阻塞队列(BlockingDeque)

 首先我们来认识一下什么是堵塞队列

阻塞队列即实现了线程安全和阻塞的队列。在队列为空时，获取元素的线程会等待队列存放元素变为非空；在队列满时，存放元素的线程会等待队列取出元素变为不满。

阻塞队列常应用于生产者-消费者模型

我们常用的阻塞队列主要有两类

LinkedBlockingDeque

ArrayBlockingQueue

使用LinkedBlockingDeque

BlockingDeque<Integer> blockingDeque = new LinkedBlockingDeque<>();

使用ArrayBlockingQueue

ArrayBlockingQueue<String> blockingDeque = new ArrayBlockingQueue<>(100);
//100表示队列容量

2、阻塞队列中常用的方法

常用的方法有三个：put()，take()，peek()

put()

put()方法用于在阻塞队列中存放元素

blockingDeque.put(1);

 take()

take()方法用于获取并取出队首元素

System.out.println(blockingDeque.take());

peek()

peek()用于获取队首元素

System.out.println(blockingDeque.peek());

3、用阻塞队列实现生产者-消费者模型

这里我们用LinkedBlockingDeque类

我们用两个线程分别来给阻塞队列添加/取出元素，以此来实现生产者/消费者模型 

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;public class demo1 {public static void main(String[] args) throws InterruptedException {BlockingDeque<Integer> blockingDeque = new LinkedBlockingDeque<>();Thread thread1 = new Thread(()->{int n = 0;while (true){try {blockingDeque.put(n);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("生产元素"+n);n++;try {Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}}});Thread thread2 = new Thread(()->{while (true){try {System.out.println("消费元素"+blockingDeque.take());} catch (InterruptedException e) {throw new RuntimeException(e);}}});thread1.start();thread2.start();}
}

运行结果

 注意：上面代码中，我们在生产者线程里使用了sleep()休眠，以此来控制生产消费的速度