QNX消息传递机制实现多任务并发功能

该示例展示了如何使用QNX消息传递机制实现多个任务之间的并发执行。使用多个线程实现多任务，每个线程都是一个独立的任务，通过QNX消息传递机制进行通信，实现任务之间的协作。

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

#define MSG_TYPE1 1
#define MSG_TYPE2 2

typedef struct {
    int type;
    int value;
} msg_t;

void *task1(void *arg) {
    int chid = *(int*)arg;
    msg_t msg;
    while (1) {
        MsgReceive(chid, &msg, sizeof(msg), NULL);
        if (msg.type == MSG_TYPE1) {
            printf("Thread1 receives msg: %d\n", msg.value);
        }
        else if (msg.type == MSG_TYPE2) {
            printf("Thread1 shutdown\n");
            break;
        }
    }
    pthread_exit(NULL);
}

void *task2(void *arg) {
    int chid = *(int*)arg;
    msg_t msg;
    msg.type = MSG_TYPE1;
    for (int i = 0; i < 5; i++) {
        msg.value = i;
        MsgSend(chid, &msg, sizeof(msg), NULL, 0);
        sleep(1);
    }
    msg.type = MSG_TYPE2;
    MsgSend(chid, &msg, sizeof(msg), NULL, 0);
    pthread_exit(NULL);
}

int main(int argc, char *argv[]) {
    int chid = ChannelCreate(0);
    pthread_t thread1, thread2;
    pthread_create(&thread1, NULL, task1, (void*)&chid);
    pthread_create(&thread2, NULL, task2, (void*)&chid);
    printf("Main thread waiting...\n");
    pthread_join(thread1, NULL);
    pthread_join(thread2, NULL);
    ChannelDestroy(chid);
    return EXIT_SUCCESS;
}

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