VxWorks任务间通信的示例代码与解决方案

VxWorks是一个嵌入式实时操作系统，提供了多任务处理能力。任务间通信对于系统的实时性和可靠性至关重要。以下示例展示了VxWorks中任务间消息传递的方式。

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

#define MAX_MSGS 50
#define MAX_MSG_LEN 20

MSG_Q_ID msgQId;

void taskSender() {
    char msg[MAX_MSG_LEN] = "Hello, receiver!";
    while (1) {
        if (msgQSend(msgQId, msg, sizeof(msg), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR) {
            printf("Failed to send message.\n");
        }
        taskDelay(100); // Delay for demonstration purpose
    }
}

void taskReceiver() {
    char receivedMsg[MAX_MSG_LEN];
    while (1) {
        if (msgQReceive(msgQId, receivedMsg, sizeof(receivedMsg), WAIT_FOREVER) == ERROR) {
            printf("Failed to receive message.\n");
        } else {
            printf("Received message: %s\n", receivedMsg);
        }
    }
}

void vxWorksTaskCommunicationExample() {
    msgQId = msgQCreate(MAX_MSGS, MAX_MSG_LEN, MSG_Q_FIFO);

    taskSpawn("senderTask", 100, 0, 2000, (FUNCPTR)taskSender, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("receiverTask", 101, 0, 2000, (FUNCPTR)taskReceiver, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
}

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