请教 multiprocessing 问题,在 window7 下运行可以正常打印, ubuntu 运行一会就卡死了。
資深大佬 : naldo0193 12
在 window7 下运行可以正常打印,ubuntu 运行一会就卡死了。
import time,os
from multiprocessing import Manager,Pool
def test_try(multiprocess_queue):
print(os.getpid())
check_multiprocess_queue = multiprocess_queue.empty()
if check_multiprocess_queue:
print(‘队列为空’)
else:
each_data = multiprocess_queue.get()
print(os.getpid())
if __name__ == ‘__main__’:
while True:
multiprocess_queue = Manager().Queue()
multiprocess_queue.put(‘a’)
pool = Pool(processes=2) # 最大核数
# 异步进程
for d in range(2):
pool.apply_async(func=test_try, args=(multiprocess_queue,))
pool.close()
pool.join()
大佬有話說 (3)