python基础一 day38 管道

Myth丶恋晨 2024-04-20 11:06 69阅读 0赞

![1700204-20190831083304758-2026664590.png][]

在两个进程里，仍然可以通信

![1700204-20190831084625256-1717319612.png][]

![1700204-20190831092259426-1164035859.png][]

![1700204-20190831095043285-862371030.png][]

![1700204-20190831095625763-1968662742.png][]

消息中间件

from multiprocessing import Pipe,Process
    
    def func(conn1,conn2):
        conn2.close()
        while True:
            try :
                msg = conn1.recv()
                print(msg)
            except EOFError:
                conn1.close()
                break
    
    if __name__ == '__main__':
        conn1, conn2 = Pipe()
        Process(target=func,args = (conn1,conn2)).start()
        conn1.close()
        for i in range(20):
            conn2.send('吃了么')
        conn2.close()

管道实现生产者消费者模型

# from multiprocessing import Lock,Pipe,Process
    # def producer(con,pro,name,food):
    #     con.close()
    #     for i in range(100):
    #         f = '%s生产%s%s'%(name,food,i)
    #         print(f)
    #         pro.send(f)
    #     pro.send(None)
    #     pro.send(None)
    #     pro.send(None)
    #     pro.close()
    #
    # def consumer(con,pro,name,lock):
    #     pro.close()
    #     while True:
    #             lock.acquire()
    #             food = con.recv()
    #             lock.release()
    #             if food is None:
    #                 con.close()
    #                 break
    #             print('%s吃了%s' % (name, food))
    # if __name__ == '__main__':
    #     con,pro = Pipe()
    #     lock= Lock()
    #     p = Process(target=producer,args=(con,pro,'egon','泔水'))
    #     c1 = Process(target=consumer, args=(con, pro, 'alex',lock))
    #     c2 = Process(target=consumer, args=(con, pro, 'bossjin',lock))
    #     c3 = Process(target=consumer, args=(con, pro, 'wusir',lock))
    #     c1.start()
    #     c2.start()
    #     c3.start()
    #     p.start()
    #     con.close()
    #     pro.close()
    
    # from multiprocessing import Process,Pipe,Lock
    #
    # def consumer(produce, consume,name,lock):
    #     produce.close()
    #     while True:
    #         lock.acquire()
    #         baozi=consume.recv()
    #         lock.release()
    #         if baozi:
    #             print('%s 收到包子:%s' %(name,baozi))
    #         else:
    #             consume.close()
    #             break
    #
    # def producer(produce, consume,n):
    #     consume.close()
    #     for i in range(n):
    #         produce.send(i)
    #     produce.send(None)
    #     produce.send(None)
    #     produce.close()
    #
    # if __name__ == '__main__':
    #     produce,consume=Pipe()
    #     lock = Lock()
    #     c1=Process(target=consumer,args=(produce,consume,'c1',lock))
    #     c2=Process(target=consumer,args=(produce,consume,'c2',lock))
    #     p1=Process(target=producer,args=(produce,consume,30))
    #     c1.start()
    #     c2.start()
    #     p1.start()
    #     produce.close()
    #     consume.close()

\# pipe 数据不安全性  
\# IPC  
\# 加锁来控制操作管道的行为 来避免进程之间争抢数据造成的数据不安全现象

\# 队列 进程之间数据安全的  
\# 管道 + 锁

转载于:https://www.cnblogs.com/wang-tan/p/11438154.html

[1700204-20190831083304758-2026664590.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/fecc21d8316842ed9d8521989ecfd907.png
[1700204-20190831084625256-1717319612.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/be652caf7d01476889d6be1729ffb877.png
[1700204-20190831092259426-1164035859.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/917b3b123f1a41d3ac98cfef65fb3a55.png
[1700204-20190831095043285-862371030.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/95133b7a395e4873a2ee6942ca4f59e0.png
[1700204-20190831095625763-1968662742.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/a3ab4ee7251749a58a076ab87db7ce73.png