1、import multiprocessing as mp
from time import sleep
import os
def work(msg):
sleep(2)
print(msg)
return 'worker return' + msg #为函数调用返回相关值
if __name__ == '__main__':
pool = mp.Pool(processes = 4)
result = []
for i in range(10):
msg = "hello %d"%i
r = pool.apply_async(work,(msg,))#向进程池中加入要执行的事件
result.append(r)
#关于多线程执行的时候返回值是有序的原因说明：因为多线程只是执行的时候顺序是无序的，但是加入时是用for 有序插入，返回的对象在for的每次循环中顺序插入新列表，所以也是有序的。
for res in result:
print(res.get())
pool.close() #关闭进程池事件加入通道，即不能再向进程池中加入事件
pool.join() #阻塞等等进程池处理事件结束后回收进程池
2、参数说明：
apply_async(func,args,kwds)
功能： 以异步的方式将要执行的事件放入进程池(异步:放入进程池后无顺序执行
)
参数：
func ： 要执行的函数
args ： 给函数按位置传参
kwds ： 给函数按照键值传参
返回值 ： 返回事件执行后的返回值对象，可以通过调用get() 函数获取事件函数return的内容
Pool()
功能：创建进程池
返回值类型：进程池对象
参数<1>的名称为(processes=整数型)用于设置进程池中进程的数量。
