python - 专业化多处理。池工作者
问题描述
我有一个项目列表和可以处理这些项目的同一服务的几个实例。我想启动一些进程,其中每个工作人员都固定到服务的特定实例,但在可以自由处理它们时将项目从同一个列表中拉出。
以多处理文档中的第一个示例为例:
from multiprocessing import Pool
def f(x):
return x*x
if __name__ == '__main__':
with Pool(5) as p:
print(p.map(f, [1, 2, 3]))
我想对其进行修改,以便f(x)
实际上(在逻辑上)更像:
def f(worker, x):
return (f'processed on worker {worker}', x*x)
在现实生活中,我可以使用哪些worker
东西来修复特定服务(例如,作为服务字典的键或类似的东西)。这可能吗?
解决方案
推荐阅读
- java - Spring AOP - Jboss:无法生成类 org.jboss.as.connector.subsystems.datasources.WildFlyDataSource 的 CGLIB 子类
- node.js - 如何在feathresjs中执行内部登录?
- ssh - 通过 LSF 启动时检索 SSH 的输出
- gradle - 强制 flink 使用不同的 kafka-clients jar
- javascript - 内部链接中的外部链接 - React 路由器
- java - 我想用spring boot插入对象类型mysql的列表
- json - 在 Angular 8 的构建期间合并两个配置文件
- c# - 计算不为空并输入到表中的行数
- javascript - 如何将文件夹路径绑定到 vuetify v-text-box?
- powershell - 如何将“y”传递给使用 PowerShell Start-Process 启动的 pscp 进程?