python自带进程池

注意:必须加 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()

图例:

    

原文地址:https://www.cnblogs.com/cxhzy/p/10002813.html