http://www.cnblogs.com/sigm/p/6186401.html
一、ConcurrentLinkedQueue
是一个适用于高并发场景下的队列,通过无锁的方式,实现了高并发状态下的高性能,通常ConcurrentLinkedQueue性能好于BlockingQueue。它是一个基于链接节点的无界线程安全队列。该队列的元素遵循先进先出的原则。头是最先加入的,尾是最近加入的,该队列不予许null元素。
方法:add()和offer()都是加入元素的方法
poll和peek都是去头元素的方法,区别在于前者会删除元素,后者不会
ConcurrentLinkedQueue<String> q = new ConcurrentLinkedQueue<String>(); q.offer("a"); q.offer("b"); q.offer("c"); q.offer("d"); q.add("e"); System.out.println(q.poll()); //a 从头部取出元素,并从队列里删除 System.out.println(q.size()); //4 System.out.println(q.peek()); //b System.out.println(q.size()); //4
二、BlockingQueue接口
ArrayBlockingQueue:基于数组的阻塞队列实现,在ArrayBlockingQueue内部,维护了一个定长数组,以便缓存队列中的数据对象,其内部没有实现读写分离,长度需要定义
ArrayBlockingQueue<String> array = new ArrayBlockingQueue<String>(5); array.put("a"); array.put("b"); array.add("c"); array.add("d"); array.add("e"); array.add("f"); //System.out.println(array.offer("a", 3, TimeUnit.SECONDS));
LinkedBlockingQueue:基于链表的阻塞队列,其内部也维持着一个数据缓冲队列(一个链表构成),之所以能够高效的处理并发数据,因为内部实现了分离锁(读写分离两个锁),从而实现生产者和消费者操作的完全并行运行,是一个无界队列。
LinkedBlockingQueue<String> q = new LinkedBlockingQueue<String>(); q.offer("a"); q.offer("b"); q.offer("c"); q.offer("d"); q.offer("e"); q.add("f"); //System.out.println(q.size()); for (Iterator iterator = q.iterator(); iterator.hasNext();) { String string = (String) iterator.next(); System.out.println(string); }
SynchronousQueue:一种没有缓冲的队列,生产者产生的数据直接会被消费者获取并消费
PriorityBlockingQueue:
DelayQueue:
时间: 2024-10-06 16:17:22