msgrcv
是一个用于接收消息队列中消息的 Linux 系统调用
以下是使用 msgsnd
和 msgrcv
实现进程间同步操作的简单示例:
#include<stdio.h>
#include <stdlib.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/types.h>
#include <unistd.h>
typedef struct {
long mtype;
char mtext[100];
} Message;
int main() {
key_t key = ftok("/tmp", 123);
int msgid = msgget(key, IPC_CREAT | 0666);
if (msgid == -1) {
perror("msgget");
exit(1);
}
Message message;
message.mtype = 1;
sprintf(message.mtext, "Hello from producer!");
if (msgsnd(msgid, &message, sizeof(message.mtext), 0) == -1) {
perror("msgsnd");
exit(1);
}
printf("Producer sent message: %s\n", message.mtext);
return 0;
}
int main() {
key_t key = ftok("/tmp", 123);
int msgid = msgget(key, 0);
if (msgid == -1) {
perror("msgget");
exit(1);
}
Message message;
message.mtype = 1;
if (msgrcv(msgid, &message, sizeof(message.mtext), 1, 0) == -1) {
perror("msgrcv");
exit(1);
}
printf("Consumer received message: %s\n", message.mtext);
return 0;
}
请注意,这只是一个简单的示例,实际应用中可能需要更复杂的同步机制。在实际项目中,你可能还需要考虑错误处理、多线程同步等问题。