库以快速构建基于zeromq的应用程序。
zmq-message-patterns的Python项目详细描述
库以快速构建基于zeromq的python应用程序。
管道
呼吸机将作业发送到多个工作进程,这些进程将结果发送到接收器。
频道:
- 呼吸机->;工人:工人的工作
- 呼吸机->;接收器:发送给工人的作业的ID,因此接收器知道是否所有作业都已完成
- 工作区->;接收器:结果
- sink->;worker:sink完成后发送关闭命令
图表:
ventilator-------------+ | | +-------+------+ | | | | | worker worker worker ... | || || || | ++------++----++ | || | sink----------------+
是examples目录(examples/pipeline_example.py)中的一个全功能示例。