线程学习--queue

Posted 2020-09-22

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: