Redis实现优先级队列

实现优先级队列

优先级队列是什么？

优先级队列 是不同于先进先出队列的另一种队列。每次从队列中取出的是具有最高优先权的元素。

redis如何实现优先级队列

关键命令：BRPOP（从队列右边弹出）/BLPOP（从队列左边弹出）

BRPOP/BLPOP和RPOP/LPOP命令类似，都是从队列里弹出一个元素，只不过BRPOP在队列没有新元素的时候会阻塞，它接受一个timeout参数，用来表示阻塞的时间，当超过该时间还是未获得新元素则会返回nil，如果为0则表示一直阻塞下去。除此之外它还可以接受多个KEY，如：>BRPOP KEY1,KEY2 TIMEOUT。

  • 如果多个KEY只有其中一个获得了新元素，则BLPOP会返回该新元素以及获得该元素的KEY
  • 如果多个KEY都获得了新元素，则会返回BLPOP/BRPOP命令后面的KEY从左到右第一个KEY的KEY和VALUE

实际操作

只有一个KEY获得新元素

  • 打开两个redis-cli实例A和B
  • 在客户端A使用BLPOP获取queue:1,queue:2,queue:3
BLPOP queue:1 queue:2 queue:3 0
  • 在客户端B往queue:2里面放一个元素
LPUSH queue:2 task
  • 回到客户端A 原本处于阻塞状态，现在输出了刚才添加的元素以及所属的KEY,如下：
  1. "queue:2" ----KEY
  2. "task" ----最新获取的元素
  3. (467.91s) ----阻塞的时长

多个KEY都获得新元素

  • 基于之前创建的客户端和队列，在客户端B往queue:2和queue:3中各放入一个新元素
LPUSH queue:2 task1
LPUSH queue:3 task2
  • 客户端A中使用BLPOP弹出新获得的元素
BLPOP queue:1 queue:2 queue:3 0

立马输出了刚才添加的元素以及所属的KEY,如下：

  1. "queue:2" -----获得新元素的所有KEY中从左到右第一个KEY
  2. "task1" -----对应KEY的VALUE

总结

通过BLPOP/BRPOP多个KEY都获得新元素时，只返回获得新元素的所有KEY中从左到右第一个KEY和对应的VALUE的特性，我们可以把想优先执行的任务队列对应的KEY放到最左边就可以实现（粗略）的优先级队列了。之所以说是“粗略”，是因为它的优先级是队列级别，优先级高的队列，里面所有的元素的优先级都比后面的队列元素优先级高；而每个队列内部还是FIFO（先进先出）。

原文地址：https://www.cnblogs.com/xuxiaojian/p/9497220.html

时间： 2024-10-11 16:15:27

Redis实现优先级队列的相关文章

用redis实现消息队列

为什么需要消息队列 系统中引入消息队列机制是对系统一个非常大的改善.例如一个web系统中,用户做了某项操作后需要发送邮件通知到用户邮箱中.你可以使用同步方式让用户等待邮件发送完成后反馈给用户,但是这样可能会因为网络的不确定性造成用户长时间的等待从而影响用户体验. 有些场景下是不可能使用同步方式等待完成的,那些需要后台花费大量时间的操作.例如极端例子,一个在线编译系统任务,后台编译完成需要30分钟.这种场景的设计不可能同步等待后在回馈,必须是先反馈用户随后异步处理完成,再等待处理完成后根据情况再此

Rabbitmq中的优先级队列操作

1.%% 普通队列操作 in(X, 0, {queue, [_] = In, [], 1}) ->{queue, [X], In, 2}; in(X, 0, {queue, In, Out, Len}) when is_list(In), is_list(Out) -> {queue, [X|In], Out, Len + 1}; 优先级队列操作: in(X, Priority, Q = {queue, [], [], 0}) -> in(X, Priority, {pqueue, []

初学算法-基于最小堆的优先级队列C++实现

笔者近日实现了最小堆类及其派生的优先级队列,特将代码奉上,不足之处还请指出! 在实现优先级队列时,笔者表示萌萌哒没有用过template写派生类,结果写完了出现error: *** was not decleared in this scope..后来各种补上this->才完事,在CSDN(笔者的帖子地址? http://bbs.csdn.net/topics/391806995)上提问后才知道是模板参数依赖,笔者表示涨姿势了.. /**  * The Minimum Heap Class an

【转】java中PriorityQueue优先级队列使用方法

优先级队列是不同于先进先出队列的另一种队列.每次从队列中取出的是具有最高优先权的元素. PriorityQueue是从JDK1.5开始提供的新的数据结构接口. 如果不提供Comparator的话,优先队列中元素默认按自然顺序排列,也就是数字默认是小的在队列头,字符串则按字典序排列. 由于网上的资料大多将优先级队列各个方法属性,很少有实例讲解的,为方便大家以后使用,我就写了个demo~ 如果想实现按照自己的意愿进行优先级排列的队列的话,需要实现Comparator接口.下面的方法,实现了根据某个变

STL学习系列七：优先级队列priority_queue容器

1.简介 最大值优先级队列.最小值优先级队列 优先级队列适配器 STL priority_queue 用来开发一些特殊的应用,请对stl的类库,多做扩展性学习 如果我们给每个元素都分配一个数字来标记其优先级,不妨设较小的数字具有较高的优先级,这样我们就可以在一个集合中访问优先级最高的元素并对其进行查找和删除操作了.这样,我们就引入了优先级队列 这种数据结构. 优先级队列(priority queue) 是0个或多个元素的集合,每个元素都有一个优先权,对优先级队列执行的操作有(1)查找(2)插入一

优先级队列及小顶堆排序

优先级队列及小顶堆排序实现 /** @file          HeapSort.h *  @copyright     personal *  @brief         优先级队列及堆排序 *  @version       V1.0.0 *  @author        fangyuan *  @date          2015/12/31 *  @note          测试版本 */ #include "iostream" using namespace std

初学图论-Dijkstra单源最短路径算法基于优先级队列(Priority Queue)的实现

这一次,笔者使用了STL库中的优先级队列(Priority Queue)来完成Dijkstra算法中extract-min()语句(即从未选中的节点中选取一个距离原点s最小的点)的功能.由于优先级队列的插入.删除操作只需要logn的时间花费,因此降低了不少运行时间. 本文使用C++实现了这一基本算法.参考<算法导论>第24.3节. /**  * Dijkstra's Single Source Shortest Path Algorithm in C++  * Time Cost : O(Ml

STL之优先级队列priority_queue

摘要: priority_queue,自适应容器(即容器适配器):不能由list来组建: 最大值优先级队列(最大值始终在对首,push进去时候) 最小值优先级队列: 优先级队列适配器 STL  priority_queue priority_queue<int, deque<int> > pg; priority_queue<int, vector<int> > pg; STL中实现的方法: pg.empty(); pg.size(); pg.top();

队列的应用：优先级队列

优先级队列:如果我们给每个元素都分配一个数字来标记其优先级,不妨设较小的数字具有较高的优先级,这样我们就可以在一个集合中访问优先级最高的元素并对其进行查找和删除操作了. 优先级队列(priority queue)是0个或多个元素的集合,每个元素都有一个优先权,对优先级队列执行的操作有(1)查找(2)插入一个新元素(3)删除 一般情况下,查找操作用来搜索优先权最大的元素,删除操作用来删除该元素 .对于优先权相同的元素,可按先进先出次序处理或按任意优先权进行. 以上是网上常见的对优先级队列的描述.偷