标签：fd1 读取 -- 写入 Pipe 管道 fd2 multiprocessing

1、管道通信

　　在内存中开辟一块空间，形成管道结构，多个进程使用同一个管道，即可通过对管道的读写操作进行通信

from multiprocessing import  Pipe

2、创建管道对象

　　fd1,fd2 = Pipe(duplex = True)

　　功能: 创建管道

　　参数：默认表示双向管道

　　　　   如果设置为False，则为单向管道

　　返回值 ： 两个管道对象，分别表示管道的两端

　　　　　　  如果是双向管道，则均可读写

　　　　　　  如果是单向管道，则fd1只读， fd2只写

3、从管道读取信息

　　fd.recv()

　　功能:从管道读取信息

　　返回值 ：读取到的内容

　　【注意】当管道为空则阻塞

4、向管道写入内容

　　fd.send(data)

　　功能: 向管道写入内容

　　参数： 要写入的内容

　　【注意】①  管道满时会阻塞  ② 可以写入几乎所有的python数据

5、其它

　　【1】q.full()

　　　　　　判断队列是否为满

　　【2】q.empty()

　　　　　　判断队列是否为空

　　【3】q.qsize()

　　　　　　获取队列中消息数量

　　【4】q.close()

　　　　　　关闭队列

from multiprocessing import Process,Pipe
import os,time 

#创建管道
fd1,fd2 = Pipe(False)

def fun(name):
    time.sleep(3)
    #向管道写入内容
    fd2.send("hello" + str(name)) 

jobs = []
for i in range(5):
    p = Process(target = fun,args = (i,))
    jobs.append(p)
    p.start()

while True:
    #从管道读取内容
    data = fd1.recv()
    print(data)

for i in jobs:
    i.join()
~             
#结果
hello0
hello1
hello3
hello2
hello4

（阻塞中...）

 

标签：fd1,读取,--,写入,Pipe,管道,fd2,multiprocessing
来源： https://www.cnblogs.com/longyuu/p/14248837.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。