蟒蛇中真正简单的多处理–然后链接到MongoDB

蟒蛇中的多处理非常简单!您可以使用 泳池()  class.

1
2
3
4
5
6
7
8
9
10
11
多处理 进口 泳池
 
定义 add_one(to_what):
    “增加整数的琐碎函数”
    返回 to_what + 1
 
池子 = 泳池(流程=4) #spawn 4个进程
数字 = [1,2,3,4] #这是我们的测试数据
结果 = 池子.地图(add_one,数字) #发送函数和每个数字1
池子.() #杀死过程
打印 结果 #将返回[2,3,4,5]

在这里,我们生成了4个进程,并使用map()函数向每个进程发送一个数字。

这是一个简单的示例,但是当每个进程执行诸如建立远程连接之类的操作时,它会变得更加强大:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
多处理 进口 泳池
pymongo 进口 连接
 
定义 多少(server_number):
    “返回集合中有多少个文档”
    c = 连接(“ 192.168.0。” + server_number) #连接到远程数据库
    返回 c.我的数据库.我的收藏.计数()
 
池子 = 泳池(流程=4)
伺服器 = [1,2,3,4]
结果 = 池子.地图(多少,伺服器)
池子.()
 
打印 “您在所有MongoDB服务器上都有{0}个文档!”.格式((结果))

发表评论