| 123456789101112131415 |
- --[[
- Function to check if queue is maxed or not.
- ]]
- local function isQueueMaxed(queueMetaKey, activeKey)
- local maxConcurrency = rcall("HGET", queueMetaKey, "concurrency")
- if maxConcurrency then
- local activeCount = rcall("LLEN", activeKey)
- if activeCount >= tonumber(maxConcurrency) then
- return true
- end
- end
- return false
- end
|