发布时间:2019-08-14 12:45:12编辑:auto阅读(1940)
#!/usr/bin/env python
from multiprocessing import Pool
import time
def sayHi(a):
time.sleep(5)
return a**a
if __name__ =="__main__":
p=Pool(processes=5)
result=p.apply_async(sayHi,[10])
print result.get()
一个池子启用5个线程池,且异步一次返回结果
可以用for循环使用多次异步:
#!/usr/bin/env python
from multiprocessing import Pool
import time
def sayHi(a):
time.sleep(5)
return a**a
p=Pool(processes=5)
result_list=[]
for i in range(100):
result_list.append(p.apply_async(sayHi,[i]))
for j in result_list:
print j.get()
上一篇: Python API 2.0
下一篇: Python 字典(Dictionary
49939
49188
39857
36899
31296
28139
27091
21889
21821
20168
66°
146°
128°
292°
317°
933°
1701°
1619°
1319°
2692°