我正在尝试设置一个链接工作池系统​​,如下所示：

 ╭────────╮                  ╭─────────╮                  ╭─────────╮
 │        ├──> Worker 1 ───> │         ├──> Worker 3 ───> │         │
 │  Data  ├──> Worker 1 ───> │  Queue  ├──> Worker 3 ───> │  Queue  ├───> Output
 │        ├──> Worker 1 ───> │         ├──> Worker 3 ───> │         │
 ╰────────╯                  ╰─────────╯                  ╰─────────╯ 
 ╭────────╮                     ^ ^ ^
 │        ├──> Worker 2 ────────┘ │ │
 │  Data  ├──> Worker 2 ──────────┘ │
 │        ├──> Worker 2 ────────────┘
 ╰────────╯                         

在我推出自己的通用解决方案之前,我可以使用任何现有的库(或干净的多处理/线程示例)吗？我不确定将这种设置称为什么,所以我的Google搜索没有给我很多有用的结果.

任何提示表示赞赏！

解决方法:

ZeroMQ是一个轻量级解决方案,具有Python绑定.
http://www.zeromq.org/bindings:python