在Linux环境下，可以使用管道（pipe）或者消息队列（message queue）来实现一个简单的生产者消费者模型。以下是使用管道实现的示例代码：
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#define BUFFER_SIZE 1024
int main() {
int pipefd[2];
pid_t pid;
char buffer[BUFFER_SIZE];
int bytes_read;
// 创建管道
if (pipe(pipefd) == -1) {
perror("pipe");
exit(EXIT_FAILURE);
}
// 创建子进程
pid = fork();
if (pid == -1) {
perror("fork");
exit(EXIT_FAILURE);
}
// 子进程作为生产者
if (pid == 0) {
close(pipefd[0]); // 关闭读端
while (1) {
const char* msg = "Hello, Consumer!";
write(pipefd[1], msg, strlen(msg)); // 写入数据到管道
sleep(1); // 生产者休眠，模拟生产速度
}
close(pipefd[1]);
exit(EXIT_SUCCESS);
} else {
close(pipefd[1]); // 关闭写端
while (1) {
bytes_read = read(pipefd[0], buffer, BUFFER_SIZE); // 从管道读取数据
if (bytes_read > 0) {
buffer[bytes_read] = '\0'; // 确保字符串以null结尾
printf("Consumer received: %s\n", buffer);
}
}
close(pipefd[0]);
wait(NULL); // 等待子进程结束
exit(EXIT_SUCCESS);
}
}这段代码创建了一个管道，并使用了fork()来创建一个子进程。父进程作为消费者，子进程作为生产者。他们通过管道进行通信。生产者定时往管道里写数据，消费者从管道中读取数据并打印。这个模型演示了同步和互斥的基本概念，是学习操作系统进程同步的一个简单例子。