BlockingQueue阻塞队列
BlockingQueue简介
juc包下，BlockingQueue很好的解决了多线程中，高效安全的"传输数据"问题。
阻塞队列，是一个队列，可以是数据从队列的一端输入，从另一端输出。
当队列空时，从队列获取元素线程被阻塞，直到其他线程向空的队列插入新元素。
当队列满时，向队列添加元素线程被阻塞，直到其他线程从队列中移除一个或多个元素或者完全清空，使队列变得空闲起来后新增。
在多线程中，阻塞是指在某些情况下，挂起线程，一旦条件满足，被挂起的线程被自动唤醒。
队列和栈
队列 FIFO(先进先出)
栈 FILO(先进后出)
常用的BlockingQueue子类
ArrayBlockingQueue(常用)
由数组结构组成的有界阻塞队列。
LinkedBlockingQueue(常用)
由链表结构组成的有界(大小默认值为Integer.MAX_VALUE)阻塞队列。
DelayQueue
使用优先级队列实现的延迟无界阻塞队列。
PriorityBlockingQueue
支持优先级排序的无界阻塞队列。
SynchronousQueue
该队列在创建时，有两种模式，公平和非公平。
公平模式会采用公平锁，并使用队列来阻塞多余的生成者和消费者，从而实现整体的公平策略。
非公平模式，采用非公平锁，且使用栈来阻塞多余的生产者和消费者，这种模式下，如果生产者和消费者的处理速度存在差距，则很容易出现饥渴的情况，即可能出现生产不足(消费者在等待生产者)，或者生产过剩(有些元素，永远不会被消费)。
总结，不存储元素的同步队列，即存储单个元素的对列。
LinkedBlockingDeque
由链表组成的双休阻塞队列。
BlockingQueue核心方法
方法使用代码
/**
* @author 长名06
* @version 1.0
*/
public class BlockingQueueDemo {
public static void main(String[] args) throws InterruptedException {
BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);
//第一组
//add方法无空间可添加元素，抛IllegalStateException("Queue full")异常 有空间可添加元素，返回true
// System.out.println(blockingQueue.add("wind-风"));//
// System.out.println(blockingQueue.add("flower-花"));
// System.out.println(blockingQueue.add("snow-雪"));
// System.out.println(blockingQueue.add("moon-月"));
//System.out.println(blockingQueue.element());
//remove方法，无元素可用，抛NoSuchElementException异常 有元素可用，返回元素
// System.out.println(blockingQueue.remove());
// System.out.println(blockingQueue.remove());
// System.out.println(blockingQueue.remove());
// System.out.println(blockingQueue.remove());
//第二组
//offer(E e)方法 无空间可添加元素，返回false 有空间可用添加元素，返回true
//还存在offer(E e)的重载方法offer(E e, long timeout, TimeUnit unit) 对应第四组
//无空间可添加元素，会等待一段时间，看是否有空间可用添加元素，等待时间内有，添加 没有就返回false
//有空间可用添加元素，返回true
// System.out.println(blockingQueue.offer("wind-风"));
// System.out.println(blockingQueue.offer("flower-花"));
// System.out.println(blockingQueue.offer("snow-雪"));
// System.out.println(blockingQueue.offer("moon-月"));
//
//poll方法，无元素可用，返回null 有元素可用，返回元素
// System.out.println(blockingQueue.poll());
// System.out.println(blockingQueue.poll());
// System.out.println(blockingQueue.poll());
// System.out.println(blockingQueue.poll());
//第三组
//put方法注释
//Inserts the specified element into this queue, waiting if necessary for space to become available.
//put方法，如果队列已满，就一直等待，直到队列可用添加元素 put方法无返回值
blockingQueue.put("wind-风");
blockingQueue.put("flower-花");
blockingQueue.put("snow-雪");
System.out.println("队列已满");
System.out.println(blockingQueue.offer("moon-月", 3L, TimeUnit.SECONDS));
// blockingQueue.put("moon-月");
//take方法注释
//Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
//take方法，不为空返回元素 如果队列为空，就一直阻塞，等待队列中有元素可用
// System.out.println(blockingQueue.take());
// System.out.println(blockingQueue.take());
// System.out.println(blockingQueue.take());
// System.out.println("队列已空");
// blockingQueue.take();
//第四组
//poll方法注释
//Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
//poll方法，取元素，如果队列不为空，返回元素
// 如果队列为空，会等待一段时间，看是否有元素可用，没有就返回null
System.out.println(blockingQueue.poll(3L, TimeUnit.SECONDS));
System.out.println(blockingQueue.poll(3L, TimeUnit.SECONDS));
System.out.println(blockingQueue.poll(3L, TimeUnit.SECONDS));
// System.out.println(blockingQueue.poll(3L, TimeUnit.SECONDS));
}
}
只是为了记录自己的学习历程，且本人水平有限，不对之处，请指正。