Python进程池的使用
#!/usr/bin/evn python# -*- coding:utf-8 -*-import multiprocessingimport timeimport threadingfrom multiprocessing import Pool,Array,Value,Queuedef simonPoolTest(name,action):print("你传入进来的...
#!/usr/bin/evn python
# -*- coding:utf-8 -*-
import multiprocessing
import time
import threading
from multiprocessing import Pool,Array,Value,Queue
def simonPoolTest(name,action):
print("你传入进来的是："+name+",操作是："+action)
time.sleep(10)
if __name__=="__main__":
# python的进程池的使用
pool = multiprocessing.Pool();
for i in range(0,10):
"""
从进程池中拿到一个进程后，直接使用apply_async的方法添加进程需
要执行的操作以及操作方法的参数
"""
pool.apply_async(simonPoolTest, args=("simon", "添加"))
"""
进程使用完后，需要通过使用close方法把进程的资源释放出来
"""
pool.close();
"""
在使用线程池的时候，必须先close，再进行join()
如果join(2)是表示 ，最多等2秒
"""
pool.join();
CSDN联合极客时间，共同打造面向开发者的精品内容学习社区，助力成长！
更多推荐
1
0- 0
已为社区贡献13条内容
所有评论(0)