发布时间:2019-08-14 12:45:12编辑:auto阅读(1978)
#!/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
50495
49799
40396
37417
31833
28696
27628
22412
22411
20726
481°
1100°
900°
835°
1080°
957°
1569°
2939°
2618°
2013°