VxWorks中实现基于消息队列的进程间通信

该示例代码演示了在VxWorks操作系统中如何利用消息队列实现进程间的通信。消息队列是一个用于进程间通信的通道，通过将消息发送到队列中并从队列中接收消息来实现进程间的数据交换。

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

#define MAX_MSG_LEN 50
#define MAX_MSGS 10

MSG_Q_ID msgQId;

void sendTask()
{
    char msg[MAX_MSG_LEN] = "Hello, World!";

    if (msgQSend(msgQId, msg, sizeof(msg), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR) {
        printf("Failed to send message\n");
    }
}

void receiveTask()
{
    char msg[MAX_MSG_LEN];
    int msgSize;

    if ((msgSize = msgQReceive(msgQId, msg, MAX_MSG_LEN, WAIT_FOREVER)) == ERROR) {
        printf("Failed to receive message\n");
    }
    else {
        msg[msgSize] = '\0'; // 添加字符串终止符
        printf("Received message: %s\n", msg);
    }
}

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

    taskSpawn("sendTask", 100, 0, 2000, (FUNCPTR)sendTask, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("receiveTask", 90, 0, 2000, (FUNCPTR)receiveTask, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
}

void main()
{
    appStart();
    taskDelay(60000);
}
'''

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