编写代码实现进程间的命名管道通信,要求创建管道实现每隔2秒种自动输出

在Unix/Linux系统中，可以使用`pipe()`函数和`fork()`、`waitpid()`等系统调用来实现进程间的消息传递，即命名管道通信。这里我会简述一种基本的Python示例，因为Python有内置的`os`模块可以直接操作文件描述符。

首先，创建一个父进程（producer），它会创建一个管道，并设置好读端和写端：

import os
import time

# 创建管道
parent_r, child_w = os.pipe()

# 每隔2秒输出消息到管道
while True:
    message = f"当前时间：{time.strftime('%Y-%m-%d %H:%M:%S')}"
    os.write(parent_r, message.encode())
    print(f"消息发送：{message}")
    time.sleep(2)

然后，在子进程中（consumer），我们通过接收管道的数据并打印出来：

# 子进程部分
def consume(pipe_w):
    while True:
        data = os.read(pipe_w, 4096)  # 每次最多读取4KB数据
        if not data:
            break
        print("消息接收：", data.decode())

if __name__ == "__main__":
    child_p = os.fork()
    
    if child_p == 0:  # 子进程
        consume(child_w)
        os.close(child_w)  # 关闭写端防止阻塞
        os._exit(0)
    else:  # 父进程
        os.close(parent_r)  # 关闭读端，由子进程处理
        os.waitpid(child_p, 0)  # 等待子进程结束

在这个例子中，父进程每隔2秒生成一个消息并通过管道写入，而子进程负责不断从管道读取并打印。当父进程关闭其读端时，子进程将退出。