进程间通信pipe

封面图 • 2023-10-28 • 嵌入式

进程间通信pipe

管道（Pipe）是一种用于进程间通信的机制，它允许一个进程向另一个进程发送数据。在 Unix/Linux 系统中，管道通常是通过 os.pipe() 函数创建的。

以下是一个简单的使用 Python 中的 os 模块创建和使用管道的示例：

创建管道：
python
```
import os

# 创建管道
read_fd, write_fd = os.pipe()
```

在子进程中写入数据：
python
```
import os

# 创建管道
read_fd, write_fd = os.pipe()

# 创建子进程
pid = os.fork()

if pid == 0:  # 子进程
    os.close(read_fd)  # 关闭读取端
    message = "Hello, parent process!"
    os.write(write_fd, message.encode())  # 写入数据到管道
    os.close(write_fd)  # 关闭写入端
    os._exit(0)
```
在父进程中读取数据：
python
```
import os

# 创建管道
read_fd, write_fd = os.pipe()

# 创建子进程
pid = os.fork()

if pid == 0:  # 子进程
    os.close(read_fd)  # 关闭读取端
    message = "Hello, parent process!"
    os.write(write_fd, message.encode())  # 写入数据到管道
    os.close(write_fd)  # 关闭写入端
    os._exit(0)
else:  # 父进程
    os.close(write_fd)  # 关闭写入端
    data = os.read(read_fd, 100)  # 从管道读取数据
    os.close(read_fd)  # 关闭读取端
    print("Received data:", data.decode())
```
在这个例子中，os.pipe() 创建了一个管道，返回两个文件描述符 read_fd 和 write_fd。然后使用 os.fork() 创建了一个子进程，子进程和父进程分别关闭了不需要的文件描述符。

子进程向管道写入数据，父进程从管道读取数据。需要注意的是，由于进程之间共享文件描述符，子进程和父进程能够直接在管道中进行通信。在实际应用中，需要确保读写操作是同步的，以避免数据的混乱。