VxWorks下如何实现并发通信

本示例演示了VxWorks下使用信号量和消息队列实现多任务之间的并发通信。

#include <vxWorks.h>
#include <semLib.h>
#include <msgQLib.h>

SEM_ID semId;
MSG_Q_ID msgQId;

void task1(void) {
    while(1){
        semTake(semId, WAIT_FOREVER);  // 等待sem信号量
        printf("Received message: %s\n", (char *)msgQReceive(msgQId, WAIT_FOREVER));
    }
}

void task2(void) {
    while(1){
        msgQSend(msgQId, "Hello World", strlen("Hello World"), WAIT_FOREVER);  // 发送消息到消息队列
        semGive(semId);  // 发出sem信号量
    }
}

int main(void) {
    semId = semBCreate(SEM_Q_FIFO, SEM_EMPTY);  // 创建sem信号量

    msgQId = msgQCreate(10, 20, MSG_Q_FIFO);  // 创建消息队列

    taskSpawn("t1", 100, 0, 2000, (FUNCPTR)task1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);  // 创建任务1
    taskSpawn("t2", 100, 0, 2000, (FUNCPTR)task2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);  // 创建任务2

    return 0;
}

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