Python：IPC-Pipe与IPC-Manger

发布时间：2020-07-30 07:27:33 所属栏目：Python 来源：互联网

导读：1，IPC-PIPE：管道 pipefrom multiprocessing import Processfrom multiprocessing import Pipep1,p2 = Pipe() #支持双向通信# sendp1.send(菠萝蜜干)# recvprint(p2.recv())p2.send(酸奶)# p2.close()print(p1.recv())print(p1.recv()) #管道里没有值会报错

1，IPC-PIPE：

管道 pipe

multiprocessing multiprocessing = Pipe() p1.send( (p1.recv())

2，用管道也能实现生产者消费者模型

multiprocessing produce,consume= baozi= ( % produce,consume= i == produce,consume= lock = c1=Process(target=consumer,args=((produce,consume), c2=Process(target=consumer, p1=Process(target=producer,10 ()

3，IPC-Manager

multiprocessing multiprocessing 3 == == m.dict({= Process(target=func,args=] =from multiprocessing import Manager,Process,Lock
def work(d,lock):
lock.acquire()
d['count'] -= 1
lock.release()

if name == 'main':
lock= Lock()
m = Manager()
dic=m.dict({'count':100}) # 共享的数据
l = []
for i in range(100):
p=Process(target=work,args=(dic,lock))
p.start()
l.append(p)
[p.join() for p in l]
print(dic)

（编辑：莱芜站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!