python 多进程multiprocessing 模块

Posted 2020-10-18 考鸡蛋

multiprocessing 常用方法：

• cpu_count():统计cpu核数

  multiprocessing.cpu_count()

• active_children() 获取所有子进程

  multiprocessing.active_children()

• preces() 创建一个进程对象

  multiprocessing.Preces(target=function_name, args=())

  target: 函数名
  
  args: 函数需要的参数，以tuple形式传入，一个参数时需（1，）

Preces 常用方法：

• is_alive() 判断进程是否存在

• run() 启动进程

• start() 启动进程，会自动调用run方法，这个常用

• join([timeout]) 等待进程结束或者直到超时
  • join() 方法说明：

  def def worker(interval):
      time.sleep(interval)
      print(‘hello world‘)
  P = multiprocessing.Process(target=worker, args=(5,))
  #-----------------------------------
  P.start()
  #设置timeout 设置超时时间
  print(P.is_alive())
  P.join(timeout=3)
  print(‘end main‘)
  ###
      True
      end main
      hello world
  #-----------------------------------
  P.start()
  P.alive()
  # 不调置timeout 超时时间
  P.join()
  print()
  ###
      True
      hello world
      end main
  #-----------------------------------
  结论：
  当join()不设置timeout时程序会一直等待上面的进程执行完成后再执行join()后面的代码
  当设置timeout时，无论上面的进程是否执行完成，程序运行到指定时间后就会执行后面的代码
  

  Preces 常用属性

• namd 进程名子

• pid 进程的pid