QNX消息传递实现并发通信机制示例

QNX提供了消息传递机制，可实现进程间通信。该示例展示了如何使用QNX消息传递实现并发通信，利用消息队列发送和接收消息，实现多进程间的数据交换。

#include <stdio.h>
#include <stdlib.h>
#include <sys/neutrino.h>

#define MY_CHANNEL 21
#define MSG_SIZE 50

int main() {
    int channel_id;
    struct _msg_info info;
    int receive_id;
    char message[MSG_SIZE];

    // 创建通道
    channel_id = ChannelCreate(0);
    if (channel_id == -1) {
        perror("ChannelCreate");
        exit(EXIT_FAILURE);
    }

    // 发送消息
    printf("Sending message: Hello from Process 1\n");
    MsgSend(channel_id, "Hello from Process 1", MSG_SIZE, NULL, 0);

    // 接收消息
    receive_id = MsgReceive(channel_id, message, MSG_SIZE, &info);
    if (receive_id == -1) {
        perror("MsgReceive");
        exit(EXIT_FAILURE);
    } else {
        printf("Received message in Process 1: %s\n", message);
    }

    // 关闭通道
    ChannelDestroy(channel_id);

    return EXIT_SUCCESS;
}

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