VxWorks中的任务同步与通信示例

本示例演示了在VxWorks实时操作系统中如何使用任务同步与通信机制，通过消息队列实现两个任务之间的数据传递与同步操作。

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

SEM_ID sem;   // 信号量用于任务同步
MSG_Q_ID msgQ; // 消息队列用于任务通信

void task1() {
    while (1) {
        semTake(sem, WAIT_FOREVER);  // 获取信号量，进入临界区
        printf("Task 1: Processing data...\n");
        semGive(sem);  // 释放信号量，退出临界区

        taskDelay(100);  // 模拟任务执行时间
    }
}

void task2() {
    while (1) {
        semTake(sem, WAIT_FOREVER);  // 获取信号量，进入临界区

        // 从消息队列接收数据
        int data;
        msgQReceive(msgQ, (char *)&data, sizeof(int), WAIT_FOREVER);
        printf("Task 2: Received data: %d\n", data);

        semGive(sem);  // 释放信号量，退出临界区

        taskDelay(200);  // 模拟任务执行时间
    }
}

void main() {
    sem = semBCreate(SEM_Q_FIFO, SEM_FULL);  // 创建信号量
    msgQ = msgQCreate(10, sizeof(int), MSG_Q_FIFO);  // 创建消息队列

    taskSpawn("t1", 100, 0, 2000, (FUNCPTR)task1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("t2", 110, 0, 2000, (FUNCPTR)task2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);

    taskDelay(5000);  // 运行5秒钟
}

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