在Python中,可以使用os.pipe()
函数来创建管道。下面是一个简单的示例:
import os
# 创建管道
r, w = os.pipe()
# 在子进程中向管道中写入数据
pid = os.fork()
if pid == 0:
os.close(r)
os.write(w, b"Hello, pipe!")
os.close(w)
else:
os.close(w)
# 在父进程中从管道中读取数据
data = os.read(r, 100)
print("Received data:", data.decode())
os.close(r)
在这个示例中,首先调用os.pipe()
函数创建了一个管道,然后使用os.fork()
函数创建了一个子进程,子进程中向管道中写入了数据,父进程中从管道中读取了数据。最后需要记得在使用完管道之后调用os.close()
函数关闭管道。