VxWorks任务同步与通信示例

本示例演示在VxWorks实时操作系统中实现任务同步与通信的方法。通过使用信号量（semaphore）和消息队列（message queue），实现不同任务之间的数据传递和同步操作。

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

SEM_ID semaphore; // 信号量
MSG_Q_ID msgQueue; // 消息队列

void task1() {
    while (1) {
        semTake(semaphore, WAIT_FOREVER); // 获取信号量
        printf("Task 1: 收到消息 - %s\n", (char *)msgQReceive(msgQueue));
        semGive(semaphore); // 释放信号量
        taskDelay(100);
    }
}

void task2() {
    while (1) {
        semTake(semaphore, WAIT_FOREVER);
        char message[] = "Hello from Task 2";
        msgQSend(msgQueue, message, sizeof(message), WAIT_FOREVER, MSG_PRI_NORMAL);
        semGive(semaphore);
        taskDelay(200);
    }
}

void vxWorksSyncDemo() {
    semaphore = semBCreate(SEM_Q_FIFO, SEM_FULL); // 创建信号量
    msgQueue = msgQCreate(10, 20, MSG_Q_FIFO); // 创建消息队列

    taskSpawn("t1", 100, 0, 2000, (FUNCPTR)task1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0); // 创建任务1
    taskSpawn("t2", 100, 0, 2000, (FUNCPTR)task2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0); // 创建任务2
}

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