perl - perl 中来自 redis 的非阻塞 blpop-6ren

perl - perl 中来自 redis 的非阻塞 blpop

转载作者：可可西里更新时间：2023-11-01 11:42:44

25

4

我有一个连续循环运行的程序

Pick one job from a Redis using BLPOP
Process the job,
LOOP

我需要做的是当工作正在进行时获得下一份工作，这样我就可以节省用于 redis blpop 的时间。我该怎么做

最佳答案

像这样:

do forever
   BLPOP next job     # from Redis
   wait               # for all background jobs to finish      
   process job &      # process job in the background
done

关于perl - perl 中来自 redis 的非阻塞 blpop，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/22779276/

25

4

0

文章推荐： android - 如何做触摸和拖动幻灯片动画

文章推荐： java - 通过 Jar 文件实现事件发布功能

php - 一段时间后 blpop 停止处理队列
在我的组织中，我们有许多 redis 工作人员来执行我们的关键任务。通常，我们的工作人员一天会停止处理队列一两次。代码基本上是这样的: while ($item = $redis->blpop(ar
php - Predis 上 BLPOP 的正确语法是什么？
我是这样做的: $r = new Predis\Client($single_server, $options); $retval = $r->blpop('queue:query'); 但是我得到这
python - Redis blpop 有时会返回元组，有时不会？
我使用以下代码在我的 Redis 队列中放置/检索项目，但有时在解码 json 转储时会出错，因为返回的项目不是元组而是完整的 json。这是类(class): class RedisQueue(o
go - 使用 BLPOP 处理 Redis 队列会导致单元测试中出现竞争条件？
我正在尝试实现一个先进先出的任务队列，如 Chapter 6.4.1 of the Redis e-book 中所述。在围棋。出于测试目的，我传入了 CommandExecutor 'worker
perl - perl 中来自 redis 的非阻塞 blpop
我有一个连续循环运行的程序 Pick one job from a Redis using BLPOP Process the job, LOOP 我需要做的是当工作正在进行时获得下一份工作，这样我就
python - Tornado -redis : LPOP works but BLPOP doesn't?
Tornado 和 Redis 的新手我发现这里有人有同样的问题，tornado-redis: RPOP works but BRPOP doesn't?但我仍然不明白为什么，以及如何解决我的问题代
Scala Redis 驱动程序 - 使用 blpop 命令
我正在尝试使用 blpop Redis 命令，它将在 10 秒超时后返回一些 Long 值: val r = new RedisClient("10.0.0.15", 6379) impli
php - 需要有关 BLPOP Predis PHP 的支持
我正在使用 BLPOP 构建聊天消息系统长轮询。我使用 Predis PHP。当我运行 test/get -> 它以 30 秒超时运行 okie。在运行 test/get 时，我尝试通过 test/
redis - 使用 BLPOP 的 redis 作业队列
我正在尝试使用 redis 和 ruby eventmachine 创建无限作业队列。为了实现这一点，我使用超时为 0 的 redis BLPOP 命令。成功 BLPOP 后，我再次运行它。我的
node.js - Nodejs redis 方法 BLPOP 阻塞事件循环
我使用库 node-redis:https://github.com/NodeRedis/node-redis let client = redis.createClient(); let blpop
performance - 对阻塞命令(例如 blpop)的 Redis 延迟进行基准测试？
我知道典型的 Redis 延迟小于 1 毫秒，但我想知道 lpush 之间延迟的典型时间(以微秒/毫秒为单位)到一个空列表，和一个 blpop返回之前阻止它的那个。我不太确定如何衡量这一点，但我也对
Redis.blPop : How check how many process wait 'key' ?
我正在使用 PhpRedis $redis->blPop('key', 10); 如何检查有多少进程等待'key'？ $redis->blPopCountWait('key'); => 30 谢谢!
python - 等待 gevent socket 和 redis 阻塞 blpop
我正在使用 gevent StreamServer 来处理来自客户端的传入连接。客户端连接后，客户端会向服务器端发送一些消息，服务器端会进行处理。这边一切正常。但有时服务器也会将消息发送回特定的客户
redis - Redis 中的 BLPOP、BRPOP 和 BRPOPLPUSH 是什么？
正在尝试研究 Redis 的指标并得出这些术语。对他们一无所知。有人可以用外行的话解释这些术语吗？最佳答案根据 REDIS Commands Documentation : BLPOP BLPOP
ruby-on-rails - 转移到 VPC 后，blpop 阻塞的时间比 Rails 进程中的超时时间长得多
我的超时时间为 3 秒，预计 blpop 最多只会挂起 3 秒，但我的 Rails 进程随机挂起的时间比这更长，有时长达 500 秒。挂起的代码是: ... if timeout # equ
node.js - Redis 队列 : call BLPOP/BRPOP inside a loop?
我想用 Redis 构建一个简单的队列系统，而不依赖于 pub/sub。所以我的 (Nodejs) 消费者将在列表中调用 BRPOP，没有什么是原创的。问题是是否完全和排他地依赖无超时 BRPOP
redis - BLPOP 和 MISCONF 配置 Redis 保存 RDB 快照
我们在 ELK 堆栈中使用 Redis 来缓冲我们系统之间的消息和 Elasticsearch 。消息由自定义 log4j-appender 推送到 redis 并由 logstash 弹出。现在出
redis - Lettuce core redis blpop 带来Type mismatch Can't assign non-array value to an array
我用的是Letuce core，下面的代码((4)点)会报错:“类型不匹配无法将非数组值分配给数组” redisListCommands.lpush("service:queue","test

首页

博学

6Ren·AI

商城

perl - perl 中来自 redis 的非阻塞 blpop