,进程池的返回值,进程池的回调函数
# apply_async(func[, args[, kwds[, callback]]]) 它是非阻塞
# apply(func[, args[, kwds]])...# terminate() 结束工作进程,不再处理未完成的任务。
# join() 主进程阻塞,等待子进程的退出, join方法要在close或terminate之后使用。...# 返回结果先 append 进列表,否则变成了单进程
from multiprocessing import Pool, JoinableQueue, Process
import time
import...print('进程号', os.getpid(), '拿到了', item)
return item + '的返回值'
def callback(item):
print(...res)
# if do something: # 关闭线程池,不再处理任务
# pool_obj.terminate()
pool_obj.join() # 主进程等待进程池的任务全部结束