#进程池创建
from multiprocessing import Pool
import sys
def work_a():for var in range(1,5):print(var) sys.stdout.flush()
def work_b():for var in range(5,10):print(var)sys.stdout.flush()
def work_c():for var in range(10,15):print(var)sys.stdout.flush()
def main():p = Pool(2) #参数：可以最多同时执行任务个数，并不是填充的最大任务个数#p.apply_async(func=work,args=(a,b),) 非阻塞行为p.apply(func=work_a)#阻塞行为p.apply(func=work_b)p.apply(func=work_c)#?: 是否是阻塞行为执行完这三个任务#阻塞的话：1个等一个，同步#非阻塞：异步p.close()p.join()
if __name__ == '__main__':main()

1
2
3
4
5
6
7
8
9
10
11
12
13
14

#获取阻塞进程池返回结果
from multiprocessing import Pool
import sys
def work_a():for var in range(1,5):print(var) sys.stdout.flush()return 'a'
def work_b():for var in range(5,10):print(var)sys.stdout.flush()return 'b'
def work_c():for var in range(10,15):print(var)sys.stdout.flush()return 'c'
def main():p = Pool(2) #参数：可以最多同时执行任务个数，并不是填充的最大任务个数res1 = p.apply(func=work_a) #阻塞的一个等一个，res1执行完才会执行res2res2 = p.apply(func=work_b)res3 = p.apply(func=work_c)print('res1进程返回结果:%s' % res1),print('res2进程返回结果:%s' % res2),print('res3进程返回结果:%s' % res3)p.close(),p.join()
if __name__ == '__main__':main()

1
2
3
4
5
6
7
8
9
10
11
12
13
14
res1进程返回结果:a
res2进程返回结果:b
res3进程返回结果:c

#获取非阻塞进程池返回结果
from multiprocessing import Pool
import sys
def work_a():for var in range(1,5):
#       print(var) sys.stdout.flush()return 'a'
def work_b():for var in range(5,10):
#       print(var)sys.stdout.flush()return 'b'
def work_c():for var in range(10,15):
#       print(var)sys.stdout.flush()return 'c'
def main():p = Pool(2) #参数：可以最多同时执行任务个数，并不是填充的最大任务个数res1 = p.apply_async(func=work_a) #非阻塞的会返回一个抽象的数据res2 = p.apply_async(func=work_b)res3 = p.apply_async(func=work_c)print('res1进程返回结果:%s' % res1.get()),print('res2进程返回结果:%s' % res2.get()),print('res3进程返回结果:%s' % res3.get())p.close(),p.join()
if __name__ == '__main__':main()

res1进程返回结果:a
res2进程返回结果:b
res3进程返回结果:c

#进程池通讯--Queue
from multiprocessing import Pool,Manager,Queue
from time import sleep
import sys
def work_a(q):#生产者 放十次for var in range(10):print('生产者:',var) sys.stdout.flush()q.put(var)sleep(1)
def work_b(q):#消费者，拿十次for var in range(10):res = q.get() #阻塞行为print('消费者:',var)sys.stdout.flush()
def main():q = Manager().Queue() #进程共享队列p = Pool(5) #进程可以复用p.apply_async(func=work_a,args={q,q})p.apply_async(func=work_b,args={q,q})p.close()p.join()
if __name__ == '__main__':main()

生产者: 0
消费者: 0
生产者: 1
消费者: 1
生产者: 2
消费者: 2
生产者: 3
消费者: 3
生产者: 4
消费者: 4
生产者: 5
消费者: 5
生产者: 6
消费者: 6
生产者: 7
消费者: 7
生产者: 8
消费者: 8
生产者: 9
消费者: 9