workerprocess 0.1.2

Worker Process

此软件包提供了一个用于创建独立工作进程的包装器。

示例工作进程

通过扩展BaseWorker类并实现一个tick方法来执行，然后调用类上的.main()来创建工作进程。这将启动一个无限循环调用该函数。

工作进程可以通过max_ticks_per_second进行速率限制。

可以通过向进程发送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()

如果进程收到SIGHUP，将调用函数上的sighup方法

运行工作进程

运行工作进程的最简单方法是向setup.py添加一个console_script入口点

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

安装您的软件包后，您可以从命令行运行example_worker_process命令。