LInkedBlockingQueue队列

偏执的太偏执、 2022-05-14 06:24 137阅读 0赞

### LInkedBlockingQueue ###

也称为无界队列  
基于链表的阻塞队列

内部维持着一个数据缓冲队列  
该队列由一个链表构成

之所以能够高效的处理并发数据  
因为，内部实现采用分离锁，读写分离两个锁  
从而，实现生产者、消费者操作的完全并行运行

package com.bjsxt.base.coll013;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.TimeUnit;
    
    import javax.swing.text.html.HTMLDocument.Iterator;
    
    public class UseQueue {
    
        public static void main(String[] args) throws Exception {
    
            // 阻塞队列
            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 (java.util.Iterator<String> iterator = q.iterator(); iterator.hasNext();) { 
                String string = (String) iterator.next();
                System.out.println(string);
            }
        }
    }

运行  
![这里写图片描述][70]

### drainTo() ###

批量的获取队列中的元素  
添加到集合中

package com.bjsxt.base.coll013;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.TimeUnit;
    
    import javax.swing.text.html.HTMLDocument.Iterator;
    
    public class UseQueue {
    
        public static void main(String[] args) throws Exception {
    
            // 阻塞队列
            LinkedBlockingQueue<String> q = new LinkedBlockingQueue<String>();
            q.offer("a");
            q.offer("b");
            q.offer("c");
            q.offer("d");
            q.offer("e");
            q.add("f");
    
            List<String> list = new ArrayList<String>();
            System.out.println(q.drainTo(list, 3));
            System.out.println(list.size());
            for (String string : list) {
                System.out.println(string);
            }
        }
    }

运行  
![这里写图片描述][70 1]

[70]: /images/20220514/97a7fe72e536413195e028b05d10625a.png
[70 1]: /images/20220514/85db8167945342ca96309abb8f79983b.png