一、进程池

进程池 map() 和 imap() 方法的实现

代码演示：


    
import multiprocessing
    
def func(name):
      print('start process {}'.format(name))
      return name.upper()
    
if __name__ == '__main__':
      p = multiprocessing.Pool(5)  # 限制每次执行的进程数为 5 个进程
      print(p.map(func,['map','map']))  # 开启一个进程
      for i in p.imap(func,['imap','imap']):  # 开启了 2 个进程
        print(i)							# 有两个参数就开启两个进程

运行结果：
在这里插入图片描述

进程池 apply_async() 的实现

代码演示：

#!/usr/bin/env python
import multiprocessing
import time

def func(name,plan):
    print('start process {} 计划'.format(plan))
    time.sleep(2)
    return name.upper()


if __name__ == '__main__':
    results = []
    p = multiprocessing.Pool(5) # 限制运行的进程数量为 5 个
    for i in range(7):          # 开启 7 个进程，而 7 个进程超过了 5 个，所以限制了 2 个进程，不给放行
        res = p.apply_async(func, args=('诸葛亮','B'))
        results.append(res)
    for i in results:
        print(i.get(2.1))  # 限制获取进程返回值的超时时间为 2.1 秒

运行结果：
在这里插入图片描述
一次只有 5 个进程在运行，另外 2 个进程，不允许运行。

这里使用列表来存储队列 Queue 对象，应该是提前用了 Queue 模块的 put() 方法，然后返回一个队列对象。

二、简单 Process 方法

代码演示：

#!/usr/bin/env python
    
from multiprocessing import Process
import os
import time
    
def func(name):
      print('start a process {}'.format(name))
      time.sleep(3)
      print('the process parent id :',os.getppid())
      print('the process id is :',os.getpid())
    
if __name__ =='__main__':
      processes = []
      for i in range(2):
        p = Process(target=func,args=(i,))
        processes.append(p)
      for i in processes:
        i.start()
      print('start all process')
      for i in processes:
        i.join()
        #pass
      print('all sub process is done!')