workerprocess 0.1.2

工作进程

这个包提供了一个包装器来创建独立的工作进程。

示例工人

工人是通过扩展baseworker类并实现一个勾号来创建的 方法执行，然后对类调用.main（）。这将启动 调用该函数的无限循环。

工人可以通过每秒的最大滴答数来限制费率。

通过向进程发送sigterm，可以优雅地停止工作进程。

>>> import time
...
... from workerprocess import BaseWorker
...
...
... class ExampleWorker(BaseWorker):
...
...     max_ticks_per_second = 10
...
...     def tick(self):
...         print 'Tick!'
...         time.sleep(1)
...
... ExampleWorker.main()

如果进程接收到 叹气

运行工作者

运行工作程序的最简单方法是添加控制台脚本 设置的入口点.py:

entry_points=”“” [console_scripts] example_worker_process = yourpackage.yourmodule:ExampleWorker.main “”“,

安装包后，您将能够运行命令 命令行中的示例工作进程。