package/delayqueue
1
0
Fork 0
mirror of https://github.com/HDT3213/delayqueue.git synced 2025-10-04 23:02:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

update pending2ReadyScript to adapt to alibaba Cloud #12

Browse Source
This commit is contained in:
finley
2024-02-12 13:01:37 +08:00
parent 8cabcf8c96
commit 461d5a1ab5
3 changed files with 19 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
delayqueue.go
View File

@@ -218,16 +218,16 @@ func (q *DelayQueue) SendDelayMsg(payload string, duration time.Duration, opts .
const pending2ReadyScript = `
local msgs = redis.call('ZRangeByScore', KEYS[1], '0', ARGV[1]) -- get ready msg
if (#msgs == 0) then return end
local args2 = {'LPush', KEYS[2]} -- push into ready
local args2 = {} -- keys to push into ready
for _,v in ipairs(msgs) do
table.insert(args2, v)
if (#args2 == 4000) then
redis.call(unpack(args2))
args2 = {'LPush', KEYS[2]}
redis.call('LPush', KEYS[2], unpack(args2))
args2 = {}
end
end
if (#args2 > 2) then
redis.call(unpack(args2))
redis.call('LPush', KEYS[2], unpack(args2))
end
redis.call('ZRemRangeByScore', KEYS[1], '0', ARGV[1]) -- remove msgs from pending
`