VxWorks任务间同步与通信解决方案

该示例代码展示了在VxWorks实时操作系统中，使用消息队列和信号量实现任务间的同步和通信。通过使用队列和信号量，可以确保任务按照指定的顺序运行，避免产生死锁和竞态条件等问题。

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

SEM_ID mySem;
MSG_Q_ID myMsgQ;

/*任务1*/
void task1(void)
{
    while(1){
        /*等待接收消息*/
        char msg;
        msgQReceive(myMsgQ, &msg, 1, WAIT_FOREVER);
        printf("Task1 received message: %c\n", msg);
        /*发送信号*/
        semGive(mySem);
    }
}

/*任务2*/
void task2(void)
{
    while(1){
        /*发送消息*/
        char msg = 'A';
        msgQSend(myMsgQ, &msg, 1, WAIT_FOREVER, MSG_PRI_NORMAL);
        printf("Task2 sent message: %c\n", msg);
        /*等待信号*/
        semTake(mySem, WAIT_FOREVER);
    }
}

/*主函数*/
void main(void)
{
     /*创建信号量*/
     mySem = semBCreate(SEM_Q_FIFO, SEM_FULL);
     /*创建消息队列*/
     myMsgQ = msgQCreate(10, 1, MSG_Q_FIFO);
     /*创建任务*/
     taskSpawn("t1", 50, 0, 10000, task1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
     taskSpawn("t2", 50, 0, 10000, task2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);

}

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