linux 线程使用消息队列，有多个发送者和一个接收者，例子

在Linux中，线程通过消息队列进行通信是非常常见的一种异步处理策略。当有多个线程作为发送者，它们需要将数据传递给单个接收者时，可以使用如`msg_queue`（系统消息队列）这样的机制。

举个简单的例子：

1. **创建消息队列**:
首先，主线程（接收者）会调用`msgget()`创建一个消息队列，并获取一个消息队列标识符mqd_t。

#include <sys/msg.h>
mqd_t msg_queue;
msg_queue = msgget(key, flags);

这里的`key`通常是一个互斥锁标识符，用于唯一确定队列；`flags`则是设置队列属性的标志。

2. **定义消息结构**:
定义一个自定义的消息结构，例如`struct my_msg`，包含必要的数据字段。

struct my_msg {
    int type; // 消息类型
    char data[100]; // 数据部分
};

3. **发送者线程**:
发送者线程调用`msgsnd()`向队列中添加消息，传入消息队列标识、消息指针以及长度等信息。

my_msg msg;
msg.type = TYPE_X;
strcpy(msg.data, "Some data");
msgrcv(msg_queue, &msg, sizeof(msg), type, 0); // 替换为实际发送操作

4. **接收者线程**:
接收者线程则负责从队列中取出消息并处理。

void* receiver(void *arg) {
    while (1) {
        struct my_msg msg;
        msgrcv(msg_queue, &msg, sizeof(msg), 0, MSG_DONTWAIT); // 使用阻塞或非阻塞模式取消息
        handle_message(&msg);
    }
}

在这个例子中，