from multiprocessing import Pool
import osdef func(i):print(i, os.getpid())if __name__ == "__main__":p = Pool(4)for i in range(10):# async 异步的提交任务p.apply_async(func, args=(i,))# 关闭池子，不是回收池子中的进程，而是阻止继续提交任务p.close()# 阻塞，直到池子中的任务都执行完毕p.join()# 运行结果：发现即使重新运行多次，最多也就出现四个进程
0 4866
1 4867
3 4866
2 4868
4 4867
5 4866
7 4866
8 4867
6 4869
9 4868# p.apply_async 要与 close/join 配合使用
# 保证主进程等待所有进程池中的任务执行完毕
# ret = p.apply_async(...)
# 在提交所有任务之后，从 ret 中获取结果(函数的返回值)
# 也能够让主进程等待池中任务完成

import os
import time
from multiprocessing import Process, Pooldef func(i):print(i, os.getpid())if __name__ == "__main__":start = time.time()p_lst = []for i in range(5):p = Process(target=func, args=(i,))p.start()p_lst.append(p)for p in p_lst:p.join()end = time.time()pro_time = end - startstart = time.time()p = Pool(4)for i in range(5):p.apply_async(func, args=(i,))p.close()p.join()end = time.time()pool_time = end - startprint("多进程所需时间：%s" % pro_time)print("进程池所需时间：%s" % pool_time)# 运行结果：
0 16738
1 16739
2 16740
3 16741
4 16742
0 16743
1 16744
2 16745
4 16743
3 16746
多进程所需时间：0.006443500518798828
进程池所需时间：0.11818265914916992

import os
import time
from multiprocessing import Pooldef func(i):time.sleep(0.1)print(i,os.getpid())if __name__ == '__main__':p = Pool(4)p.map(func,range(5))# 运行结果：
0 17333
2 17335
1 17334
3 17336
4 17333# 这里 p.map(func,range(5)) 相当于：
for i in range(5):p.apply_async(func, args=(i,))
p.close()
p.join()

import os
import time
from multiprocessing import Pooldef func(i):time.sleep(1)print(i,os.getpid())return i**iif __name__ == '__main__':p = Pool(4)ret_lst = []for i in range(10):ret = p.apply_async(func,args=(i,))ret_lst.append(ret)p.close()p.join()for ret in ret_lst:print(ret.get())# 运行结果：
0 17517
2 17519
1 17518
3 17520
4 17517
6 17518
5 17519
7 17520
9 17517
8 17518
1
1
4
27
256
3125
46656
823543
16777216
387420489

import time
import random
from multiprocessing import Process,Pool# 进程池的子进程执行这个函数的
def get(i):time.sleep(random.random())print('从网页获取一个网页的内容', i)return i,'网页的内容'*i# 主进程执行这个函数
def call_back(content):print(content)if __name__ == '__main__':p = Pool(5)ret_l = []for i in range(10):p.apply_async(get,args=(i,),callback=call_back)p.close()p.join()# 运行结果：
从网页获取一个网页的内容 4
(4, '网页的内容网页的内容网页的内容网页的内容')
从网页获取一个网页的内容 0
(0, '')
从网页获取一个网页的内容 3
(3, '网页的内容网页的内容网页的内容')
从网页获取一个网页的内容 6
(6, '网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容')
从网页获取一个网页的内容 1
(1, '网页的内容')
从网页获取一个网页的内容 8
(8, '网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容')
从网页获取一个网页的内容 5
(5, '网页的内容网页的内容网页的内容网页的内容网页的内容')
从网页获取一个网页的内容 2
(2, '网页的内容网页的内容')
从网页获取一个网页的内容 9
(9, '网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容')
从网页获取一个网页的内容 7
(7, '网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容网页的内容')