38. Python 多进程Manager 进程池
import multiprocessingimport time
def worker(msg):
print ("#######start {0}########".format(msg))
time.sleep(1)
print ("#######end {0}########".format(msg))
if __name__ == "__main__":
pool = multiprocessing.Pool(processes=3)
for i in xrange(1, 10):
msg = "hello{0}".format(i)
pool.apply(func=worker, args=(msg,))
pool.close()
pool.join() #调用join之前，先调用close函数，否则会出错。执行完close后不会有新的进程加入到pool,join函数等待所有子进程结束
print ("main end")
页:
[1]