python 多进程的使用demo

#以下是循环使用多进程,跑run方法,args后面是run方法跟的参数
#
from multiprocessing import Pool
len = 1
def run(c1, c2, c3):
   pass

def main():
  c1 = ""
  c2 = ""
  c3 = ""
  while len>0:
      # len = redisWriteserv.llen(redis_key)
      res = pool.apply_async(run, args=(c1,c2,c3))
      len = len - 1
      # 等待所有进程执行完成
      # res.wait()
  pool.close()
  pool.join()

if __name__ == '__main__':
main()

  

python官方建议:废弃apply,使用apply_async

  

原文地址:https://www.cnblogs.com/fh-fendou/p/10490835.html