注意:必须加 close() 和 join(),且 close 必须在 join 之前
代码:
import multiprocessing
#执行方法
def func(*args,**kwargs):
print(args,kwargs)
pool = multiprocessing.Pool(4)
pool.apply_async(target = func,args = (1,3),kwds = {"name":"A"}) #注意这里是 ' kwds = '
pool.close() #注意顺序
pool.join()
图例: