原 阻塞队列 BlockingQueue的使用（二）

版权声明：本文为博主原创文章，请尊重他人的劳动成果，转载请附上原文出处链接和本声明。
本文链接：https://www.91mszl.com/zhangwuji/article/details/1141

BlockingQueue 的核心方法：

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<String> 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<String> 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)方法时，移除的是指定的元素。

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<String> 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 检查队列是否为空。