一个非常简单的作业队列。使用基本的事件循环并在子流程中运行任务(使用signalfd管理)。不支持任务参数。任务结果是基本的(只有成功或失败的退出代码)。当对同一个任务发出多个请求时,它们将折叠为一个请求。
stampede的Python项目详细描述
一个非常简单的作业队列。使用基本的事件循环并在子流程中运行任务(使用signalfd管理)。 不支持任务参数。任务结果是基本的(只有退出代码的成功或失败)。当多重 请求是为同一个任务发出的,它们被折叠成一个请求。
- 自由软件:BSD 2条款许可证
安装
pip install stampede
文档
使用项目:
importstampedeclassMyWorker(StampedeWorker):defhandle_task(self,name):print("Perfoming work for task:",name)
开发
要运行所有测试,请运行:
tox
更改日志
2.0.0(2018-12-17)
- 使用更健壮的子出口代码集合。如果有足够的压力,信号FD被充满 需要额外的os.waitpid()调用来收集孤儿。
- 添加请求api(stampede.request)。
- 添加一个请求api,如果没有运行,它也会生成守护进程(stampede.request_and_spawn)。
- 在踩踏工人中将do_work更改为handle_task。向后不兼容
- 更新测试网格以包含Python3.7和PyPy3。
- 更改了将结果传递给客户端的方式(json而不是一些糟糕的自定义文本格式)。
1.0.0(2015-10-19)
- 切换到signalfd (来自未维护的python-signalfd)。
- 切换到pytest。
0.0.1(2013-10-30)
- 是吗?
0.0.1(2013-10-28)
- pypi上的第一个版本。