demo.rar_DEMO_message queue ta_task queue

#include <vxWorks.h> #include <stdio.h> #include <string.h> #include <stdlib.h> #include <semLib.h> #include <taskLib.h> #include <msgQLib.h> #include <logLib.h> #include <ioLib.h> #define MAX_MSGS 10 #define MAX_MSG_LEN 100 #define DELAY_TICKS 50 #define STACK_SIZE 20000 int taskManage; int taskSingal; int taskSend; int taskRev; int i=1; /*定义信号量，消息队列*/ SEM_ID synSemId; MSG_Q_ID msgQId1; MSG_Q_ID msgQId2; MSG_Q_ID msgQId3; MSG_Q_ID msgQId4; /*函数声明*/ STATUS progStart(void); STATUS tManage(void); STATUS tSingal(void); STATUS tSend(void); STATUS tRev(void); /*创建各种信号量、任务、消息队列*/ STATUS progStart(void) { synSemId=semBCreate(SEM_Q_FIFO,SEM_EMPTY); /*创建信号量*/ /*创建四个任务*/ taskManage = taskSpawn("taskManage", 200, 0, STACK_SIZE, (FUNCPTR)tManage,0,0,0,0,0,0,0,0,0,0); taskSingal = taskSpawn("taskSingal", 130, 0, STACK_SIZE, (FUNCPTR)tSingal,0,0,0,0,0,0,0,0,0,0); taskSend = taskSpawn("taskSend", 130, 0, STACK_SIZE, (FUNCPTR)tSend,0,0,0,0,0,0,0,0,0,0); taskRev = taskSpawn("taskRev", 130, 0, STACK_SIZE, (FUNCPTR)tRev,0,0,0,0,0,0,0,0,0,0); /*创建消息队列*/ msgQId1=msgQCreate(MAX_MSGS,MAX_MSG_LEN,MSG_Q_PRIORITY); msgQId2=msgQCreate(MAX_MSGS,MAX_MSG_LEN,MSG_Q_PRIORITY); msgQId3=msgQCreate(MAX_MSGS,MAX_MSG_LEN,MSG_Q_PRIORITY); msgQId4=msgQCreate(MAX_MSGS,MAX_MSG_LEN,MSG_Q_PRIORITY); return(OK); } /*taskManage管理函数*/ STATUS tManage(void) { char msgbuf[50] = {'\0'}; char msgexit[50]= "exit"; taskDelay(DELAY_TICKS); printf("The initial has done!\n"); semFlush(synSemId); FOREVER { msgQReceive(msgQId1, msgbuf, MAX_MSG_LEN, WAIT_FOREVER); if(strcmp(msgbuf,msgexit)==0) { logMsg("\nThe system will be ended\n",0,0,0,0,0,0); semDelete(synSemId); taskDelete(taskSingal); taskDelete(taskSend); taskDelete(taskRev); logMsg("\nGoodbye!\n",0,0,0,0,0,0); taskDelete(taskManage); } else { logMsg(msgbuf,0,0,0,0,0,0); } } } /*开始信号激励函数*/ STATUS tSingal(void) { printf("The system is initialling...\n"); printf("Task2 initialization is OK!\n"); semTake(synSemId,WAIT_FOREVER); for(i;i<=20;i++) { if(msgQSend(msgQId3, "begin", sizeof("begin"), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR) return(ERROR); if(msgQSend(msgQId4, "begin", sizeof("begin"), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR) return(ERROR); taskDelay(DELAY_TICKS); } if(msgQSend(msgQId1, "exit", sizeof("exit"), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR) return ERROR; } STATUS tSend(void) { char msgBuf[20]; char msgErro[50] = "The message is erro!\n"; printf("Task3 initialization is OK!\n"); semTake(synSemId,WAIT_FOREVER); FOREVER { if(msgQReceive(msgQId3, msgBuf, MAX_MSG_LEN, WAIT_FOREVER) == ERROR) return(ERROR); if((strlen(msgBuf)!=0)&&(strcmp(msgBuf,"begin"))==0) { printf("The task3 received message from the task2 is:"); printf("%s",msgBuf); printf("\n"); } if(msgQSend(msgQId4, "Sending", sizeof("Sending"), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR) return(ERROR); if((strlen(msgBuf)!=0)&&(strcmp(msgBuf,"Receiving"))==0) { printf("The task3 received message from the task4 is:"); printf("%s",msgBuf); printf("\n"); } else if(msgQSend(msgQId1, msgErro, sizeof(msgErro), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR) return(ERROR); memset(msgBuf,0,20); } return (OK); } /*接收回复函数*/ STATUS tRev(void) { char msgBuf[20]; char msgErro[50] = "The message is erro!\n"; printf("Task4 initialization is OK!\n"); semTake(synSemId,WAIT_FOREVER); FOREVER { if(msgQReceive(msgQId4, msgBuf, MAX_MSG_LEN, WAIT_FOREVER) == ERROR) { return(ERROR); } if((strlen(msgBuf)!=0)&&(strcmp(msgBuf,"begin"))==0) { printf("The task4 received message from the task2 is:"); printf("%s",msgBuf); printf("\n"); } if((strlen(msgBuf)!=0)&&(strcmp(msgBuf,"Sending"))==0) { printf("The task4 received message from the task3 is:"); printf("%s",msgBuf); printf("\n"); if(msgQSend(msgQId3, "Receiving", sizeof("Receiving"), WAIT_FOREVER, MSG_PRI_NORMAL) == ERROR) return(ERROR); } } return (OK); }