queue:创建任务队列,添加和接受作业,监视失败的任务

时间:2024-06-03 09:10:35
【文件属性】:

文件名称:queue:创建任务队列,添加和接受作业,监视失败的任务

文件大小:67KB

文件格式:ZIP

更新时间:2024-06-03 09:10:35

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)

网友评论