QNX实时操作系统下多线程通信示例

本示例展示了在QNX实时操作系统中使用消息传递进行多线程通信的方法。通过创建两个线程，一个发送消息，一个接收消息，演示了在QNX环境下实现简单而高效的线程间通信的过程。

#include <stdio.h>
#include <pthread.h>
#include <mqueue.h>

// 定义消息结构体
typedef struct {
    int data;
    char message[50];
} Message;

// 发送消息的线程函数
void *sendMessage(void *arg) {
    mqd_t mq;
    struct mq_attr attr = {0};
    attr.mq_maxmsg = 10;
    attr.mq_msgsize = sizeof(Message);

    // 打开或创建消息队列
    mq = mq_open("/my_queue", O_CREAT | O_RDWR, 0644, &attr);

    // 发送消息
    Message msg = {42, "Hello from sender!"};
    mq_send(mq, (const char *)&msg, sizeof(Message), 0);

    // 关闭消息队列
    mq_close(mq);

    pthread_exit(NULL);
}

// 接收消息的线程函数
void *receiveMessage(void *arg) {
    mqd_t mq = mq_open("/my_queue", O_CREAT | O_RDWR, 0644, NULL);

    // 接收消息
    Message receivedMsg;
    mq_receive(mq, (char *)&receivedMsg, sizeof(Message), NULL);

    // 打印接收到的消息
    printf("Received: %d, %s\n", receivedMsg.data, receivedMsg.message);

    // 关闭消息队列
    mq_close(mq);

    pthread_exit(NULL);
}

int main() {
    pthread_t sender, receiver;

    // 创建发送消息的线程
    pthread_create(&sender, NULL, sendMessage, NULL);

    // 创建接收消息的线程
    pthread_create(&receiver, NULL, receiveMessage, NULL);

    // 等待线程结束
    pthread_join(sender, NULL);
    pthread_join(receiver, NULL);

    return 0;
}

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com