互斥锁和进程之间的通信

1 # 1.可以往队列里放任意类型的
 2 # 2.先进先出
 3 from multiprocessing import Process,Queue
 4 q= Queue(3)
 5 q.put('first')  #默认block=True
 6 q.put('second')
 7 q.put('third')
 8 
 9 print(q.get())
10 print(q.get())
11 print(q.get())

1 from multiprocessing import Process,Queue
 2 import os
 3 import time
 4 import random
 5 #首先得有生产者和消费者
 6 # 生产者制造包子
 7 '''这种用 q.put(None)放进去一个None的方法虽然解决了问题
 8 但是如果有多个生产者多个消费者，或许框里面没有包子了但是
 9 还有其他的食物呢，你就已经显示空着，这样也可以解决，就是不完美，
10 还可以用到JoinableQueue去解决'''
11 def producter(q):
12     for i in range(10):
13         time.sleep(2) #生产包子得有个过程，就先让睡一会
14         res = '包子%s'%i #生产了这么多的包子
15         q.put(res)  #吧生产出来的包子放进框里面去
16         print('3[44m%s制造了%s3[0m'%(os.getpid(),res))
17     q.put(None) #只有生产者才知道什么时候就生产完了（放一个None进去说明此时已经生产完了）
18 # 消费者吃包子
19 def consumer(q):
20     while True:#假如消费者不断的吃
21         res = q.get()
22         if res is None:break #如果吃的时候框里面已经空了，就直接break了
23         time.sleep(random.randint(1,3))
24         print('3[41m%s吃了%s3[0m' % (os.getpid(),res))
25 if __name__ == '__main__':
26     q = Queue()
27     p1 = Process(target=producter,args=(q,))
28     p2 = Process(target=consumer,args=(q,))
29     p1.start()
30     p2.start()
31     p1.join()
32     p2.join()  #等待执行完上面的进程，在去执行主
33     print('主')

1 from multiprocessing import Process,JoinableQueue
 2 import os
 3 import time
 4 import random
 5 #首先得有生产者和消费者
 6 # 消费者吃包子
 7 def consumer(q):
 8     '''消费者'''
 9     while True:#假如消费者不断的吃
10         res = q.get()
11         time.sleep(random.randint(1,3))
12         print('3[41m%s吃了%s3[0m' % (os.getpid(),res))
13         q.task_done() #任务结束了（消费者告诉生产者，我已经吧东西取走了）
14 # 生产者制造包子
15 def producter(q):
16     '''生产者'''
17     for i in range(5):
18         time.sleep(2) #生产包子得有个过程，就先让睡一会
19         res = '包子%s'%i #生产了这么多的包子
20         q.put(res)  #吧生产出来的包子放进框里面去
21         print('3[44m%s制造了%s3[0m'%(os.getpid(),res))
22     q.join()
23 
24 if __name__ == '__main__':
25     q = JoinableQueue()
26     p1 = Process(target=producter,args=(q,))
27     p2 = Process(target=consumer,args=(q,))
28     p2.daemon = True #在启动之前吧消费者设置成守护进程，p1结束了p2也就结束了
29     p1.start()
30     p2.start()
31     p1.join() #在等生产者结束（生产者结束后，就不制造包子了，那消费者一直在吃，就卡住了
32     #都不生产了还吃啥，就把消费者也结束了  ）
33       #等待执行完上面的进程，在去执行主
34     print('主')

1 from multiprocessing import Process,JoinableQueue 2 import os 3 import time 4 import random 5 #首先得有生产者和消费者 6 # 消费者吃包子 7 def consumer(q): 8 while True: 9 res = q.get() 10 time.sleep(random.randint(1,3)) 11 print('\033[41m%s吃了%s\033[0m' % (os.getpid(),res)) 12 q.task_done() #任务结束了（消费者告诉生产者，我已经吧东西取走了） 13 def product_baozi(q): 14 for i in range(5): 15 time.sleep(2) 16 res = '包子%s' % i 17 q.put(res) 18 print('\033[44m%s制造了%s\033[0m' % (os.getpid(), res)) 19 q.join() #不用put(None) 了，在等q被取完。（如果数据没有被取完，生产者就不会结束掉） 20 def product_gutou(q): 21 for i in range(5): 22 time.sleep(2) 23 res = '骨头%s' % i 24 q.put(res) 25 print('\033[44m%s制造了%s\033[0m' % (os.getpid(), res)) 26 q.join() 27 def product_doujiang(q): 28 for i in range(5): 29 time.sleep(2) 30 res = '豆浆%s' % i 31 q.put(res) 32 print('\033[44m%s制造了%s\033[0m' % (os.getpid(), res)) 33 q.join() 34 35 if __name__ == '__main__': 36 q = JoinableQueue() 37 # 生产者们：厨师们 38 p1 = Process(target=product_baozi,args=(q,)) 39 p2 = Process(target=product_doujiang,args=(q,)) 40 p3 = Process(target=product_gutou,args=(q,)) 41 42 #消费者们：吃货们 43 p4 = Process(target=consumer,args=(q,)) 44 p5 = Process(target=consumer,args=(q,)) 45 p4.daemon = True 46 p5.daemon = True 47 # p1.start() 48 # p2.start() 49 # p3.start() 50 # p4.start() 51 # p5.start() 52 li = [p1,p2,p3,p4,p5] 53 for i in li: 54 i.start() 55 p1.join() 56 p2.join() 57 p3.join() 58 print('主')