• 7.11. 有界阻塞队列（Bounded Blocking Queue）

    7.11. 有界阻塞队列（Bounded Blocking Queue）

    基于Redis的Redisson分布式有界阻塞队列（Bounded Blocking Queue）结构的RBoundedBlockingQueue Java对象实现了java.util.concurrent.BlockingQueue接口。该对象的最大容量受Redis限制，最大元素数量是4 294 967 295个。队列的初始容量（边界）必须在使用前设定好。

    1. RBoundedBlockingQueue<SomeObject> queue = redisson.getBoundedBlockingQueue("anyQueue");
    2. // 如果初始容量（边界）设定成功则返回`真（true）`，
    3. // 如果初始容量（边界）已近存在则返回`假（false）`。
    4. queue.trySetCapacity(2);
    6. queue.offer(new SomeObject(1));
    7. queue.offer(new SomeObject(2));
    8. // 此时容量已满，下面代码将会被阻塞，直到有空闲为止。
    9. queue.put(new SomeObject());
    11. SomeObject obj = queue.peek();
    12. SomeObject someObj = queue.poll();
    13. SomeObject ob = queue.poll(10, TimeUnit.MINUTES);

    poll, pollFromAny, pollLastAndOfferFirstTo和take方法内部采用话题订阅发布实现，在Redis节点故障转移（主从切换）或断线重连以后，内置的相关话题监听器将自动完成话题的重新订阅。