【文件属性】:
文件名称:queue:创建任务队列,添加和接受作业,监视失败的任务
文件大小:67KB
文件格式:ZIP
更新时间:2021-05-14 15:23:55
Lua
Tarantool的持久队列实现的集合
#目录
使用队列模块
初始化
创建一个新队列
设置队列设置
会话识别
将任务放入队列
从队列中提取任务(“消耗”)
确认任务已完成
下达任务
偷看任务
埋葬任务
踢很多任务
删除任务
丢队
获取统计数据
实施细节
队列驱动程序
驱动程序API
队列类型
fifo一个简单的队列
特征:
如果只有一个使用者,则按照严格的FIFO顺序安排任务。
如果有许多并发使用者,则FIFO顺序平均保留,但不太严格:并发使用者可以按不同顺序完成任务。
创建fifo队列时,可以指定以下选项:
temporary -布尔值-如果为true,则内容不保留在磁盘上(队列仅在内存中)
if_not_exists布尔值-如果为true,则如果该管已经存在,则不会返回任何错误
on_task_change函数名称-每个操作都将执行的回调; 预期的函数语法为functi
【文件预览】:
queue-master
----.travis.yml(3KB)
----cmake()
--------FindTarantool.cmake(2KB)
----Jenkinsfile(177B)
----rpm()
--------tarantool-queue.spec(1KB)
----test.sh(550B)
----t()
--------benchmark()
--------120-take-task-after-reconnect.t(2KB)
--------050-ttl.t(2KB)
--------001-tube-init.t(832B)
--------140-register-driver-after-cfg.t(1KB)
--------100-limfifottl.t(2KB)
--------000-init.t(1KB)
--------090-grant-check.t(5KB)
--------170-register-driver-after-reload.t(1KB)
--------070-compat.t(2KB)
--------150-lazy-start.t(933B)
--------040-utubettl.t(9KB)
--------110-disconnect-trigger-check.t(3KB)
--------160-validate-space.t(3KB)
--------180-work-with-uuid.t(6KB)
--------010-fifo.t(10KB)
--------130-release-all-tasks-on-start.t(1KB)
--------tnt()
--------030-utube.t(5KB)
--------060-async.t(1KB)
--------080-otc-cb.t(1KB)
--------020-fifottl.t(9KB)
----queue-scm-1.rockspec(1KB)
----LICENSE(1KB)
----debian()
--------control(606B)
--------docs(10B)
--------tarantool-queue.install(167B)
--------changelog(143B)
--------compat(2B)
--------copyright(2KB)
--------rules(30B)
--------.gitignore(49B)
--------source()
----doc()
--------images()
--------src()
----.gitignore(192B)
----CMakeLists.txt(958B)
----README.md(27KB)
----queue()
--------util.lua(1KB)
--------abstract.lua(21KB)
--------compat.lua(3KB)
--------CMakeLists.txt(1KB)
--------abstract()
--------init.lua(3KB)