rom multiprocessing import Pool
import timeimport osimport random**p = Pool(3)**
def worker(msg):
start_time = time.time() print("开始执行进程 %d ----- %s" % (msg, os.getpid())) time.sleep(random.random()*2)
stop_time = time.time() print(msg, '耗费时间是 %0.2f'% (stop_time-start_time))for i in range(0,10):
p.apply_async(worker, (i,))print("-----start-----")
p.close()
p.join()print("------END-------")为什么p = pool(3)如果写在def worker(msg)的上面,程序就会报错呢?如果写在def worker(msg)的下面就运行正常,网上没找到答案,求大神解答,感谢。
添加回答
举报
0/150
提交
取消