7.18. 优先阻塞队列（Priority Blocking Queue）

基于Redis的分布式无界优先阻塞队列（Priority Blocking Queue）Java对象的结构与java.util.concurrent.PriorityBlockingQueue类似。可以通过比较器（Comparator）接口来对元素排序。PriorityBlockingQueue的最大容量是4 294 967 295个元素。

  1. RPriorityBlockingQueue<Integer> queue = redisson.getPriorityBlockingQueue("anyQueue");
  2. queue.trySetComparator(new MyComparator()); // 指定对象比较器
  3. queue.add(3);
  4. queue.add(1);
  5. queue.add(2);
  7. queue.removeAsync(0);
  8. queue.addAsync(5);
  10. queue.take();

当Redis服务端断线重连以后，或Redis服务端发生主从切换，并重新建立连接后，断线时正在使用poll，pollLastAndOfferFirstTo或take方法的对象Redisson将自动再次为其订阅相关的话题。