为多个队列编写使用者的最佳方法

2024-09-28 17:31:34 发布

您现在位置:Python中文网/ 问答频道 /正文

我的情况如下:

我有一个简单的Redis包装器。它所做的是,它接受一个项目(dict)作为输入,并通过RPUSH将其放入链表数据类型中。在一个队列中放置新项目的请求实际上可能会产生许多新队列

现在我想读取每个队列中最左边的项目,而不进行LPOP。我需要这些物品留在队列中。所以我要做的是,我做一个LRANGE,从队列中获取最左边的项目

我的问题是我不知道如何为我的队列编写消费者。我假设每个队列应该有一个消费者?这意味着我会有很多消费者的例子,听起来像是一个糟糕的设计决策

我是否应该只获取所有队列的所有键,并在它们之间循环,反复处理最左边的项

我应该如何为我拥有的队列编写我的消费者? 我真的被卡住了,似乎没有一个标准的生产者/消费者实现能回答我的问题。我也研究过redis数据流,但我不能使用这些数据流,因为我无法做出决定


Tags: 项目redis队列情况消费者物品dict例子