VxWorks下消息、信号量的使用和任务创建
/****************************************************************************************************/
//Test.c
#include <stdlib.h>
#include <stdio.h>
#include "Test.h"
#include <taskLib.h>
#include <msgQLib.h>
#include <semLib.h>
#define MAX_MESSAGE_COUNT 100
#define MAX_MESSAGE_LENGTH 400
int offset;
unsigned char SharedBuf[2*1024];
/*任务1 消息的发送*/
void loop1(MSG_Q_ID id)/*the function for task 1, like a thread under Windows or Unix*/
{
unsigned char msg[MAX_MESSAGE_LENGTH] = {1};
for( ; ;)
{
taskDelay(10);//快速发送消息，10ms，直至消息队列满
if (msgQSend(id, msg, MAX_MESSAGE_LENGTH, WAIT_FOREVER, MSG_PRI_NORMAL) == OK)
{
printf("longping1!! Send %d\n", msg[0]);
}
else
{
printf("Sending message ERROR!\n");
}
}
}
/*任务2 消息的接收*/
void loop2(MSG_Q_ID id)/*the function for test 2, like a thread under Wondows or Unix*/
{
unsigned char msg[MAX_MESSAGE_LENGTH] = {0};
for( ; ;)
{
taskDelay(30);//满速取消息，消息队列满了以后，收发达到平衡，发消息的10ms和30ms效果相同
if (msgQReceive(id, msg, MAX_MESSAGE_LENGTH, WAIT_FOREVER) != ERROR)
{
printf("looping2!! Receive %d\n", msg[0]);
}
else
{
printf("Receiving message ERROR!\n");
}
}
}
/*任务3 获取信号量，信号量减1操作*/
void loop3(SEM_ID semID)
{
for ( ; ;)
{
taskDelay(100);//获取信号量，速度快
if (semTake(semID, WAIT_FOREVER) == OK)
{
offset = (++offset) % 2048;
printf("looping3!! Take SemID is: %d.Now I get one element: %d\n", (int)semID, SharedBuf[offset]);
}
}
}
/*任务4 释放信号量，信号量加1操作*/
void loop4(SEM_ID semID)
{
for ( ; ;)
{
taskDelay(200);//释放信号量，速度慢，可以控制获取信号量，虽然获取延时短，但是没有释放信号量，只能等待
if (semGive(semID) == OK)
{
printf("looping4!! Gave SemID is: %d.Now I get one element: %d\n", (int)semID, SharedBuf[offset]);
}
}
}
void InitialSharedBuf()
{
int i;
offset = 0;
for (i=0; i<2048; i++)
{
SharedBuf[i] = i;
}
}
int main()
{
MSG_Q_ID msgID;
SEM_ID semID;
signed int taskArray[100] = {0};
char ch;
int i;
/*to build a message Queue.*/
InitialSharedBuf();
msgID = msgQCreate(MAX_MESSAGE_COUNT, MAX_MESSAGE_LENGTH, MSG_Q_FIFO);
semID = semBCreate(SEM_Q_FIFO, SEM_FULL);
/*下面启动4个任务*/
/*start a task(thread)*/
taskArray[0] = taskSpawn("loop1 ", 80, 0, 64*1024, (FUNCPTR)loop1, (MSG_Q_ID)msgID, 0, 0, 0, 0, 0, 0, 0, 0, 0);
/*start another task(thread)*/
taskArray[1] = taskSpawn("loop2 ", 80, 0, 64*1024, (FUNCPTR)loop2, (MSG_Q_ID)msgID, 0, 0, 0, 0, 0, 0, 0, 0, 0);
/*start another task(thread)*/
taskArray[2] = taskSpawn("loop3 ", 80, 0, 64*1024, (FUNCPTR)loop3, (SEM_ID)semID, 0, 0, 0, 0, 0, 0, 0, 0, 0);
/*start another task(thread)*/
taskArray[3] = taskSpawn("loop4 ", 80, 0, 64*1024, (FUNCPTR)loop4, (SEM_ID)semID, 0, 0, 0, 0, 0, 0, 0, 0, 0);
/*主任务循环，当接收到'e'结束所有任务*/
for ( ; ;)
{
ch = getchar();
if (ch == 'e')
{
i = 0;
while (taskArray[i])
{
taskDelete(taskArray[i]);
printf("The task: %d is ended.\n", taskArray[i]);
taskArray[i] = 0;
i ++;
}
break;
}
}
printf("The Main Function is Ended.\n");
return 0;
}
/**************************************************************************************/
上面演示了消息、信号量和任务的创建，在Turnado下编译调试过，没有问题。
zhangggdlt
2005.04.28