在上一节中详细分析了LinkedBlockingQueue的实现原理。实现一个可扩展的队列通常有两种方式：一种方式就像LinkedBlockingQueue一样使用链表，也就是每一个元素带有下一个元素的引用，这样的队列原生就是可扩展的；另外一种就是通过数组实现，一旦队列的大小达到数组的容量的时候就将...
分类：
编程语言 时间：
2014-12-03 00:01:43
阅读次数：
488
在《并发容器 part 4 并发队列与Queue简介》节中的类图中可以看到，对于Queue来说，BlockingQueue是主要的线程安全版本。这是一个可阻塞的版本，也就是允许添加/删除元素被阻塞，直到成功为止。BlockingQueue相对于Queue而言增加了两个操作：put/take。下面是一...
分类：
编程语言 时间：
2014-12-02 23:54:50
阅读次数：
296
BlockingQueue ArrayBlockingQueue LinkedBlockingQueue....
分类：
编程语言 时间：
2014-11-30 16:52:34
阅读次数：
199
转载自：http://www.cnblogs.com/jackyuj/archive/2010/11/24/1886553.html前言： 在新增的Concurrent包中，BlockingQueue很好的解决了多线程中，如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类，为我们快.....
分类：
编程语言 时间：
2014-11-27 20:18:22
阅读次数：
243
ArrayBlockingQueue是个有数组支持的有界的阻塞队列。该队列按照先进先出FIFO的原理对元素排序，插入新元素市场队列的尾部，获取新元素是操作队列的开始处。一旦见了建立了缓存区，就不能再增加其容量，试图从已满的队列中方式元素会导致操作阻塞；试图从空的队列中提取元素将导致阻塞。
提拱了四种方法，只有put(),take()才会发生阻塞。
下面是阻塞队列的例子。
packag...
分类：
编程语言 时间：
2014-11-09 19:35:51
阅读次数：
229
importjava.io.File;
importjava.util.concurrent.BlockingQueue;
importjava.util.concurrent.LinkedBlockingQueue;
importjava.util.concurrent.atomic.AtomicInteger;
/**
*多线程抓取数据的简单程序
*/
publicclassMultithreadFetcher{
/**阻塞队列的最大长度，防止内存..
分类：
编程语言 时间：
2014-11-06 20:19:21
阅读次数：
281
1、阻塞队列 BlockingQueue是线程安全的Queue版本，从它的名字就可以看出，它是一个支持阻塞的Queue实现：当向空BlockingQueue请求数据时，它会阻塞至BlockingQueue非空；当向一个已满BlockingQueue插入数据时，线程会阻塞至BlockingQueu.....
分类：
编程语言 时间：
2014-10-12 18:50:48
阅读次数：
302
类似于Java阻塞队列的实现：public class BlockingQueue { private List queue = new LinkedList(); private int limit = 10;//缓冲区大小 public BlockingQueue(int limit){...
分类：
编程语言 时间：
2014-10-09 02:34:37
阅读次数：
197
工作中多处接触到了ThreadPoolExecutor。趁着现在还算空，学习总结一下。前记：jdk官方文档（javadoc）是学习的最好，最权威的参考。文章分上中下。上篇中主要介绍ThreadPoolExecutor接受任务相关的两方面入参的意义和区别，池大小参数corePoolSize和maxim...
分类：
编程语言 时间：
2014-10-06 16:16:40
阅读次数：
303
阻塞队列:
1)BlockingQueue该接口提供了:
add()/remove() 如果当队列没有数据,从队列中取数据;或者队列中数据已满,
向队列中添加数据;则会抛出异常.
put()/take() 如果当队列没有数据,从队列中取数据;或者队列中数据已满,
向队列中添加数据;则会形成阻塞.
offer()/poll() 会给调用者返回特殊的值,开发者可以通过这些值做相应的处理
...
分类：
编程语言 时间：
2014-09-29 20:43:13
阅读次数：
297
