我发现了相似的链接,但没有完全相同的问题。该程序挂在map_async上,并且从未完成,我可以看到正在创建Python进程,但它从未完成:
import multiprocessing
def main():
PROCESSES = 4
print 'Creating pool with %d processes\n' % PROCESSES
pool = multiprocessing.Pool(PROCESSES)
r = pool.map_async(pow3, range(10))
r.wait()
def pow3(x):
try:
return x**3
except:
print('%s: %s' % (x, traceback.format_exc()))
if __name__ == '__main__':
main()
相关分类