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;
}
請注意,這只是一個簡單的示例,實際應用中可能需要更復雜的同步機制。在實際項目中,你可能還需要考慮錯誤處理、多線程同步等問題。