进程通信IPC机制

一、进程间通信

from multiprocessing import Queue

q = Queue(5) # 括号内可以传参数，表示的是这个队列的最大存储数
# 往队列中添加数据
q.put(1)
q.put(2)
q.put(3)
print((q.full())) #判断队列是否满了
q.put(4)
q.put(5)
print(q.full())
q.put(6) # 当队列满了之后 再放入数据 不会报错 会原地等待 直到队列中有数据被取走(阻塞态)

print(q.get())
print(q.get())
print(q.get())
print(q.empty()) #判断队列中的数据是否取完
print(q.get())
print(q.get())
print(q.empty())
print(q.get_nowait()) # 取值 没有值不等待直接报错
print(q.get()) # 当队列中的数据取完之后 再次获取 程序会阻塞 直到有人往队列中放入值

'''
full
get_nowait
empty
都不适用于多进程的情况
'''

二、进程间通信PCI机制

from multiprocessing import Process,Queue

def producer(q):
    q.put('hey guy')

def cousumer(q):
    print(q.get())


if __name__ == '__main__':
    q = Queue()
    p = Process(target=producer,args=(q,))
    c = Process(target=cousumer,args=(q,))
    p.start()
    c.start()

三、生产者消费者模型

from multiprocessing import Process,JoinableQueue
import time
import random

def producer(name,food,q):
    for i in range(10):
        data = '%s制作了%s'%(name,food)
        time.sleep(random.random())
        q.put(data)
        print(data)

def consumer(name,q):
    while True:
        data = q.get()
        if data == None:break
        print('%s吃了%s'%(name,data))
        time.sleep(random.random())
        q.task_done() #告诉队列你已经从队列中取出了一个数据 并且处理完毕了

if __name__ == '__main__':
    q = JoinableQueue()
    p = Process(target=producer,args=('大厨egon','黄焖鸡米饭',q))
    p1 = Process(target=producer,args=('跟班tank','生蚝',q))
    c = Process(target=consumer,args=('吃货jerry',q))
    c1 = Process(target=consumer,args=('吃货jason',q))
    p.start()
    p1.start()
    c.daemon = True
    c1.daemon = True
    c.start()
    c1.start()
    p.join()
    p1.join()

    q.join() # 等待队列中数据全部取出