7.16. 优先队列(Priority Queue)

基于Redis的Redisson分布式优先队列(Priority Queue)Java对象实现了java.util.Queue的接口。可以通过比较器(Comparator)接口来对元素排序。

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