当前位置: 首页 > 知识库问答 >
问题:

redis中的并发优先级队列?

葛奇
2023-03-14

我想在Redis中实现一个并发优先级队列,不同机器上的多个进程添加项目(带分数),多个其他进程弹出这些项目,最先得分。

可以使用LPUSH和RPOP实现简单队列。

使用ZSET,我可以使用ZADD添加项目,并使用ZRANGE和ZREM弹出它们,只要只有一个读取器。

对于多个读者,我想我需要像ZPOP这样的东西,它将ZRANGE和ZREM结合在一个原子操作中。否则,两个阅读器可能会在ZREM之前从ZRANGE获得相同的项。如果ZREM返回0,重试可以工作,但不可取。

有什么方法可以使用当前的Redis命令执行此操作吗?有什么原因还没有添加到Redis中吗?这似乎是一个非常简单的命令来实现。

共有3个答案

吴驰
2023-03-14

您可以使用redis命令:watch

WATCH zset
element = ZRANGE zset 0 0
MULTI
ZREM zset element
EXEC

如果exec失败(返回空回复),只需重复这些命令。

袁法
2023-03-14

从Redis 5.0.0中,您可以使用ZPOPMIN和ZPOPMAX(以及它们的阻塞对应物BZPOPMIN和BZPOPMAX)。

申屠乐池
2023-03-14

如果使用执行ZRANGE的Lua脚本,则可以保证原子性

我假设ZPOP一开始没有被放入,因为它不是一个常见的用例,并且在需要的时候,它可以很容易地编写脚本。

 类似资料:
  • 我需要一个优先级队列,它首先获得具有最高优先级值的项目。我当前正在使用队列库中的PriorityQueue类。但是,这个函数只先返回值最小的项。我尝试了一些很难看的解决方案,比如(sys.maxint-priority)作为优先级,但我只是想知道是否存在更优雅的解决方案。

  • 我试图实现Dijkstra算法的一个版本,以找到公共汽车从起点到终点的最短路线。不幸的是,我似乎找不到swift提供优先级队列类型的库或其他方式,所以我似乎必须自己编写代码。 话虽如此,有人能指出我做这件事的正确方向吗? 目前我的想法如下: 到目前为止这是我的代码。似乎太短太残忍了...我一定是在概念上漏掉了什么。

  • 注意:我知道可以用比较器创建优先级队列,然后重复调用Add。

  • 考虑下面的优先级类声明<代码>类优先级队列 我的想法: 我能想到的一件事是,这将强制优先级队列使用对象比较器,并且不会提供实现其自定义比较器的能力,因为类的用户可能希望基于某个不同的比较器构建队列。

  • 优先级队列(Priority Queue) 注:队列是一种特征为FIFO的数据结构,每次从队列中取出的是最早加入队列中的元素。但是,许多应用需要另一种队列,每次从队列中取出的应是具有最高优先权的元素,这种队列就是优先级队列(Priority Queue),也称为优先权队列。 1. 优先级队列的概念 1.1 优先级队列的定义 优先级队列是不同于先进先出队列的另一种队列。每次从队列中取出的是具有最高优

  • 这是我写的Dijkstra算法的代码: 在这方面我不能理解的工作 这涉及到: < code>()运算符在这里有什么用?我是说它在这段代码中是如何运作的? 还有为什么我们使用