Java并发系列9--阻塞队列BlockingQueue

谁借莪１个温暖的怀抱￠ 2021-09-20 05:10 423阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

今天要讲的`BlockingQueue`可谓是大名鼎鼎，在并发编程中比较常见的一个类。

`BlockingQueue`顾名思义是表示一个阻塞队列，注意这两个词：阻塞和队列。可以拿我们熟悉的生产者-消费者队列来举例，一条流水线上，A生产零件，B组装零件，A就是生产者，B是消费者。如果A生成的太快，则零件堆积，A需要休息一会儿等待B把零件消费完；如果A生产的太慢，则B变得无活可干，被迫休息。

在`BlockingQueue`中`offer()`和`put()`就是把零件放到队列中，`poll()`和`take()`就是从队列中取出零件进行消费。需要注意的是`put()`和`take()`是阻塞方法，而`offer()`和`poll()`是非阻塞方法，也就是`put()`的时候队列满了，则阻塞；而`offer()`的时候队列满了，则返回false，不阻塞。`take()`和`poll()`方法同理。

`BlockingQueue`是一个接口，使用起来比较简单。他的实现类如下：  
![a3a672f28fdf9dff409e5efcad7d719b8b2.jpg][]  
比较常用的是`ArrayBlockingQueue`和`LinkedBlockingQueue`，从名字也可以看出来，`ArrayBlockingQueue`适合做有界队列，`LinkedBlockingQueue`适合做无界队列。  
这里只看一下简单使用：

ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(10);
    		queue.put("abc");
    		queue.take();

一般来说`put()`和`take()`方法会分散在两个或多个线程中。

--------------------

如果你的好奇心比较重，想研究一下`BlockingQueue`的实现原理，那么当你看一下`ArrayBlockingQueue`的源码，就会发现一些有趣的东西：

/** Main lock guarding all access */
        final ReentrantLock lock;
    
        /** Condition for waiting takes */
        private final Condition notEmpty;
    
        /** Condition for waiting puts */
        private final Condition notFull;

啊哈，就是我们前面讲过的`ReentrantLock`和`Condition`了，请参考：[https://my.oschina.net/lizaizhong/blog/1825244][https_my.oschina.net_lizaizhong_blog_1825244]

转载于:https://my.oschina.net/lizaizhong/blog/1840206

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20210726/eee2bad86b0445d2bb1e92bbbd4f5985.png
[a3a672f28fdf9dff409e5efcad7d719b8b2.jpg]: /images/20210726/616b6be2a3e14102af3004bfcdf0aae6.png
[https_my.oschina.net_lizaizhong_blog_1825244]: https://my.oschina.net/lizaizhong/blog/1825244