Java中Queue和BlockingQueue的区别
2015-06-29 00:32
537 查看
内容主要来自jdk的api,大家可参考jdkapi
1.BlockingQueue:支持两个附加操作的 Queue,这两个操作是:检索元素时等待队列变为非空,以及存储元素时等待空间变得可用。
2.BlockingQueue 不接受 null 元素。
3.BlockingQueue 可以是限定容量的。
4.BlockingQueue 实现是线程安全的。Queue不是线程安全的。因此可以将Blockingqueue用于用于生产者-使用者队列。
根据Api修改的一个例子,大家可以修改自己体验BlockingQueue的使用
1.BlockingQueue:支持两个附加操作的 Queue,这两个操作是:检索元素时等待队列变为非空,以及存储元素时等待空间变得可用。
2.BlockingQueue 不接受 null 元素。
3.BlockingQueue 可以是限定容量的。
4.BlockingQueue 实现是线程安全的。Queue不是线程安全的。因此可以将Blockingqueue用于用于生产者-使用者队列。
根据Api修改的一个例子,大家可以修改自己体验BlockingQueue的使用
package test; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; /** * 生产者 * @author wasw100 */ class Producer implements Runnable { private final BlockingQueue queue; Producer(BlockingQueue q) { queue = q; } public void run() { try { for (int i = 0; i < 3; i++) { queue.put(produce()); System.out.println("生产后:"+queue.peek()); } } catch (InterruptedException ex) { ex.printStackTrace(); } } Character produce() { char c = (char) (Math.random() * 26 + 'A'); System.out.println("生产前:" + c); return c; } } /** * 消费者 * @author wasw100 */ class Consumer implements Runnable { private final BlockingQueue queue; Consumer(BlockingQueue q) { queue = q; } public void run() { try { while (true) { consume(queue.take()); //Thread.sleep(100); } } catch (InterruptedException ex) { ex.printStackTrace(); } } void consume(Character c) { System.out.println("消费:" + c); } } /** * 一个生产者、两个消费者 * * @author wasw100 */ class Setup { public static void main(String[] args) { BlockingQueue q = new ArrayBlockingQueue(1); Producer p = new Producer(q); Consumer c1 = new Consumer(q); Consumer c2 = new Consumer(q); new Thread(p).start(); new Thread(c1).start(); new Thread(c2).start(); } } |
相关文章推荐
- NavigationController中设置UINavigationBar的样式
- ArduinoYun教程之ArduinoYun硬件介绍
- ROS学习 —— qt_gui_main() found no plugin matching ‘xxx' 解决方法
- LeetCode Unique Paths II
- LeetCode Unique Paths
- iOS-UI控件之UITableView(一)
- U盘安装Win7
- [php] UEditor编辑器及常见问题
- requestWindowFeature使用详解
- UITableView -registerClass:forCellReuseIdentifier:
- Android开发UI之textview实现高亮显示并点击跳转
- Android中的Handler, Looper, MessageQueue和Thread.关系
- UItabBarItem 添加图片不显示的问题解决办法
- Java Fluent Restful API自动化测试框架
- GCD和NSOperationQueue添加依赖的方法
- 《Java程序设计》第16周周四:GUI编程及文件对话框的使用
- LeetCode Permutation Sequence
- 关于UIView的autoresizingMask属性的研究
- bluestacks手机模拟器安装qq或微信时,鼠标左键点聊天编辑框后会自动输入 c 字母
- 关于 apue.h 的使用方法