VxWorks中任务间通信的实现方式

任务间通信是实现多任务协同和资源共享的关键。本示例介绍了在VxWorks中通过队列实现任务间通信的方法。

#include "vxWorks.h"
#include "stdio.h"
#include "stdlib.h"
#include "msgQLib.h"

/* 定义消息队列ID */
MSG_Q_ID myMsgQId;  

/* 定义发送和接收的消息结构体 */
typedef struct msg{
    int value1;
    int value2;
}MSG;

/* 发送消息函数 */
void sendMsg()
{
    MSG msg;
    msg.value1 = 100;
    msg.value2 = 200;
    /* 发送消息 */
    if(msgQSend(myMsgQId, (char *)&msg, sizeof(MSG), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR){
        printf("消息发送失败\n");
    }else{
        printf("消息发送成功\n");
    }
}

/* 接收消息函数 */
void receiveMsg()
{
    MSG msg;
    /* 接收消息 */
    if(msgQReceive(myMsgQId, (char *)&msg, sizeof(MSG), WAIT_FOREVER) == ERROR){
        printf("消息接收失败\n");
    }else{
        printf("消息接收成功，value1=%d，value2=%d\n", msg.value1, msg.value2);
    }
}

void myTask(void)
{
    while(1){
        sendMsg();
        receiveMsg();
        taskDelay(100);
    }
}

void startTask()
{
    /* 创建消息队列 */
    myMsgQId = msgQCreate(10, sizeof(MSG), MSG_Q_FIFO);
    /* 创建任务 */
    taskSpawn("myTask", 100, 0, 20000, (FUNCPTR)myTask, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
}

void deleteTask()
{
    /* 删除任务 */
    taskDelete(taskNameToId("myTask"));
    /* 删除消息队列 */
    msgQDelete(myMsgQId);
}

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