请教 multiprocessing 问题，在 window7 下运行可以正常打印， ubuntu 运行一会就卡死了。

[naldo0193]

在 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()

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()

[AlohaV2]

没有对齐对于 python 代码来说是很致命的，比如我不知道 while True 的作用范围是什么

[dingwen07]

你这没缩进让人怎么看

[lzp729]

linux 默认是 fork