今天要讲的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是一个接口,使用起来比较简单。他的实现类如下:
比较常用的是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