原

阻塞队列 BlockingQueue的使用(二)

BlockingQueue 的核心方法：方法类型抛出异常特殊值阻塞超时

插入add(e)offer(e)put(e)offer(e,time,unit)

移除remove()poll()take()poll(time,unit)

检查element()peek()不可用不可用

方法类型描述

抛出异常(1)抛出异常当阻塞队列满时,再往队列里面add插入元素会抛IllegalStateException: Queue full

(2)当阻塞队列空时,再往队列Remove元素时候回抛出NoSuchElementException

特殊值(1)插入方法,成功返回true失败返回false

(2)移除方法,成功返回元素,队列里面没有就返回null

阻塞(1)当阻塞队列满时,生产者继续往队列里面put元素,队列会一直阻塞直到put数据or响应中断退出。

(2)当阻塞队列空时,消费者试图从队列take元素,队列会一直阻塞消费者线程直到队列可用

超时当阻塞队列满时,队列会阻塞生产者线程一定时间,超过后限时后生产者线程就会退出

BlockingQueue add方法的使用，代码如下：package com.mszl.thread;

import java.util.concurrent.ArrayBlockingQueue;

import java.util.concurrent.BlockingQueue;

/**

* 功能：阻塞队列演示

* 备注：更多资料请访问 http://www.91mszl.com

* @author bobo teacher

*/

public class BlockingQueueDemo {

public static void main(String[] args) {

BlockingQueue bq=new ArrayBlockingQueue<>(5); // 设置最大容量为5

bq.add("A");

bq.add("B");

bq.add("C");

bq.add("D");

bq.add("E");

System.out.println(bq);

bq.add("F");

}

}

执行结果：[A, B, C, D, E]

Exception in thread "main" java.lang.IllegalStateException: Queue full

at java.util.AbstractQueue.add(AbstractQueue.java:98)

at java.util.concurrent.ArrayBlockingQueue.add(ArrayBlockingQueue.java:312)

at com.mszl.thread.BlockingQueueDemo.main(BlockingQueueDemo.java:23)

备注：我们往BlockingQueue里面添加A，B，C，D，E 五个元素时，都正常，当超过五个时，报Exception in thread "main" java.lang.IllegalStateException: Queue full

BlockingQueue add方法的使用，代码如下：package com.mszl.thread;

import java.util.concurrent.ArrayBlockingQueue;

import java.util.concurrent.BlockingQueue;

/**

* 功能：阻塞队列演示

* 备注：更多资料请访问 http://www.91mszl.com

* @author bobo teacher

*/

public class BlockingQueueDemo {

public static void main(String[] args) {

BlockingQueue bq=new ArrayBlockingQueue<>(5); // 设置最大容量为5

bq.add("A");

bq.add("B");

bq.add("C");

bq.add("D");

bq.add("E");

System.out.println(bq);

bq.remove(); // 移除最前面的那一个元素(先进先出)

System.out.println(bq);

bq.remove("D");

System.out.println(bq);

}

}

执行结果：[A, B, C, D, E]

[B, C, D, E]

[B, C, E]

备注：使用remove()方法时，移除的是队列的第一个元素(即先进先出)，如果使用remove(e)方法时，移除的是指定的元素。

BlockingQueue

element  方法的使用，代码如下：package com.mszl.thread;

import java.util.concurrent.ArrayBlockingQueue;

import java.util.concurrent.BlockingQueue;

/**

* 功能：阻塞队列演示

* 备注：更多资料请访问 http://www.91mszl.com

* @author bobo teacher

*/

public class BlockingQueueDemo {

public static void main(String[] args) {

BlockingQueue bq=new ArrayBlockingQueue<>(5); // 设置最大容量为5

bq.add("A");

bq.add("B");

bq.add("C");

bq.add("D");

bq.add("E");

System.out.println(bq);

bq.remove(); // 移除最前面的那一个元素(先进先出)

bq.remove(); // 移除最前面的那一个元素(先进先出)

bq.remove(); // 移除最前面的那一个元素(先进先出)

bq.remove(); // 移除最前面的那一个元素(先进先出)

// bq.remove(); // 移除最前面的那一个元素(先进先出)

System.out.println(bq.element());

}

}

执行结果：[A, B, C, D, E]

E

备注：element()的作用：1 检查队列第一个元素是谁；2 检查队列是否为空。