VxWorks中常见的任务同步机制

介绍VxWorks中常见的任务同步机制，包括二值信号量、计数信号量、消息队列等，并结合示例代码演示实现方式。

#include "vxWorks.h"
#include "semLib.h"
#include "msgQLib.h"
#include "taskLib.h"

SEM_ID binarySem;
SEM_ID countingSem;
MSG_Q_ID msgQ;

void task1()
{
    semTake(binarySem, WAIT_FOREVER);
    printf("Task 1 has acquired the binary semaphore.\n");
}

void task2()
{
    semGive(binarySem);
    printf("Task 2 has given the binary semaphore.\n");
}

void task3()
{
    semTake(countingSem, WAIT_FOREVER);
    printf("Task 3 has acquired the counting semaphore.\n");
}

void task4()
{
    semGive(countingSem);
    printf("Task 4 has given the counting semaphore.\n");
}

void task5()
{
    char message[10];
    msgQReceive(msgQ, message, 10, WAIT_FOREVER);
    printf("Task 5 has received a message: %s\n", message);
}

void task6()
{
    char message[] = "Hello";
    msgQSend(msgQ, message, strlen(message) + 1, WAIT_FOREVER, MSG_PRI_NORMAL);
    printf("Task 6 has sent a message.\n");
}

int main()
{
    binarySem = semBCreate(SEM_Q_PRIORITY, SEM_FULL);
    countingSem = semCCreate(SEM_Q_PRIORITY, 0);
    msgQ = msgQCreate(10, 10, MSG_Q_FIFO);

    taskSpawn("t1", 100, 0, 2000, (FUNCPTR)task1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("t2", 100, 0, 2000, (FUNCPTR)task2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("t3", 100, 0, 2000, (FUNCPTR)task3, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("t4", 100, 0, 2000, (FUNCPTR)task4, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("t5", 100, 0, 2000, (FUNCPTR)task5, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
    taskSpawn("t6", 100, 0, 2000, (FUNCPTR)task6, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
}

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