VxWorks中的任务间通信示例

本示例展示了通过消息队列实现任务间通信的简单方法。其中包括了消息队列的创建、发送和接收。在本示例中，一个发送方任务向消息队列发送消息，接收方任务从消息队列中接收消息，并进行处理。

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

#define MSG_Q_SIZE 10
#define MSG_SIZE   sizeof(int)

MSG_Q_ID msgQId;

void sendMsgTask() 
{
    int msg = 42;
    int status;

    status = msgQSend(msgQId, (char*)&msg, MSG_SIZE, WAIT_FOREVER, MSG_PRI_NORMAL);
    if (status != OK) {
        printf("发送消息失败\n");
    }
}

void recvMsgTask() 
{
    int msg;
    int status;

    status = msgQReceive(msgQId, (char*)&msg, MSG_SIZE, WAIT_FOREVER);
    if (status != OK) {
        printf("接收消息失败\n");
    } else {
        printf("收到消息：%d\n", msg);
    }
}

int main()
{
    msgQId = msgQCreate(MSG_Q_SIZE, MSG_SIZE, MSG_Q_PRIORITY);

    taskSpawn("sendMsgTask", 100, 0, 5000, sendMsgTask, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("recvMsgTask", 100, 0, 5000, recvMsgTask, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);

    taskDelay(sysClkRateGet() * 10);

    msgQDelete(msgQId);

    return 0;
}

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