2021
03-05
03-05
解决Python 进程池Pool中一些坑
1frommultiprocessingimportPool,Queue。其中Queue在Pool中不起作用,具体原因未明。解决方案:如果要用Pool创建进程,就需要使用multiprocessing.Manager()中的Queue,与multiprocessing中的Queue不同q=Manager().Queue()#Manager中的Queue才能配合Poolpo=Pool()#无穷多进程2使用进程池,在进程中调用io读写操作。例如:p=Pool()q=Manager().Queue()withopen('/home/cctv/data/stage_file/stage_{}.txt'.format(int(tim...
继续阅读 >