使用vxWorks实现多任务之间的通信

本示例展示了如何在vxWorks操作系统中实现多任务之间的通信，通过消息队列来传递数据。 通过创建几个任务，将数据放入和取出消息队列中，实现了多任务之间的通信。实现方式比较简单，是通过任务间消息队列的方式来进行数据交换。

#include "vxWorks.h"
#include "taskLib.h"
#include "msgQLib.h"

#define MSG_Q_MAX_MSGS 10
#define MSG_Q_MAX_MSG_LENGTH 32

MSG_Q_ID msgQId;

void ProducerTask(void)
{
    while(1)
    {
        char *msg = "producer message";
        int msgLength = strlen(msg) + 1;
        msgQSend(msgQId,msg,msgLength,WAIT_FOREVER,MSG_PRI_NORMAL);
        taskDelay(100); //延迟100个系统时钟滴答
    }
}

void ConsumerTask(void)
{
    while(1)
    {
        char msg[MSG_Q_MAX_MSG_LENGTH];
        memset(msg,0,MSG_Q_MAX_MSG_LENGTH);
        int msgLength = msgQReceive(msgQId,msg,MSG_Q_MAX_MSG_LENGTH,WAIT_FOREVER);
        printf("Receive Message:%s\n",msg);
    }
}

void MultipleTaskCommDemo(void)
{
    msgQId = msgQCreate(MSG_Q_MAX_MSGS,MSG_Q_MAX_MSG_LENGTH,MSG_Q_FIFO);
    taskSpawn("ProducerTask",200,0x100,10000,(FUNCPTR)ProducerTask,0,0,0,0,0,0,0,0,0,0);
    taskSpawn("ConsumerTask",200,0x100,10000,(FUNCPTR)ConsumerTask,0,0,0,0,0,0,0,0,0,0);
}

void test(void)
{
    MultipleTaskCommDemo();
}

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