一个非常简单的作业队列。使用原始的事件循环并在子进程中运行任务（通过signalfd管理）。不支持任务参数。任务结果非常基础（只有成功或失败以及退出代码）。当对同一任务进行多次请求时，它们将合并为一个请求。
项目描述
一个非常简单的作业队列。使用原始的事件循环并在子进程中运行任务（通过signalfd管理）。不支持任务参数。任务结果非常基础（只有成功或失败以及退出代码）。当对同一任务进行多次请求时，它们将合并为一个请求。
免费软件：BSD 2条款许可证
安装
pip install stampede
文档
使用项目
import stampede
class MyWorker(StampedeWorker):
def handle_task(self, name):
print("Perfoming work for task:", name)开发
要运行所有测试，请运行
tox
变更日志
2.0.0 (2018-12-17)
使用更健壮的子进程退出代码集合。结果是，如果压力足够大，signalfd会填满并需要额外的os.waitpid()调用以收集孤儿进程。
添加请求API（stampede.request）。
添加请求API，如果未运行则启动守护进程（stampede.request_and_spawn）。
将StampedeWorker中的do_work更改为handle_task。向后不兼容
更新测试网格以包括Python 3.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上的首次发布。
下载文件
下载适合您平台的文件。如果您不确定该选择哪个，请了解有关安装包的更多信息。
源代码分发
stampede-2.0.0.tar.gz (16.9 kB 查看哈希值)
构建分发
stampede-2.0.0-py2.py3-none-any.whl (8.5 kB 查看哈希值)
关闭
stampede-2.0.0.tar.gz的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 26f5382e09e4ae5b058e6b913374922c67fafa8f3304244c9be712bada8f9215 |
|
| MD5 | 0e0dc5e4c74603278eda3a079d604161 |
|
| BLAKE2b-256 | d422841b3a947c87323f48f636dfe709f9996bc86ba2c9a17dff18d7539bfb88 |
关闭
stampede-2.0.0-py2.py3-none-any.whl的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | c19f5c0da6f8c1e29bfe2b2d8966a2709d1a836e19e65b25ecd1c782afbecb39 |
|
| MD5 | b9450b45c5a30a49eca21620a27c3ea5 |
|
| BLAKE2b-256 | 51039d08bb3cb8ec9d4e58010ee76710ec8fdd8bf782ebf2e37036bfdc242ae1 |