EEPW论坛

代码如下：
#include "vxworks.h"
#include "msgQLib.h"
#include "taskLib.h" /*to use task the program should include taskLib.h */
#include "timers.h" /*to use the time function*/
#include "string.h"
#include "semLib.h" /*to use semphore the program only need inlude semLib.h*/
#include "stdio.h" SEM_ID semId; /*ID of the mutual semphore*/
int taskSemTakeId;
int taskSemTake1Id; /*Id of the task of semTake 1*/
int taskSemTake2Id;
int taskSemTake3Id;
int taskSemGive1Id; /*Id of the task of semGive 1*/
int taskSemGive2Id;
int taskSemCreateId; /*declaration of the task function*/
LOCAL void taskSemTake1(); /*the high priority task*/
LOCAL void taskSemTake2(); /*the high priority task*/
LOCAL void taskSemTake3(); /*the high priority task*/
LOCAL void taskSemGive1(); /*the low priority task*/
LOCAL void taskSemGive2(); /*the low priority task*/
LOCAL void taskSemCreate(); /*the low priority task*/
int createTsemTake(int iteration);
int createTsemGive(int iteration);
int createTsemCreate();
LOCAL int takeSem(); LOCAL void taskSemCreate()
{ struct Tag_timespec
{
time_t tv_sec; /*second*/
long tv_nsec; /**/
}current_time; semId=semMCreate(SEM_Q_PRIORITY); /*Create the semphore*/ if(semId==NULL)
{
printf("Can't create a mutual semphore!\n");
/*There should be some code here to deal with the error and exit*/
}/*if*/ clock_gettime(CLOCK_REALTIME,(timespec*)¤t_time);
printf("In time:%ld",current_time.tv_nsec);
printf("success to create the mutual semphore!\n");
}/*taskSemCreate*/
LOCAL void taskSemTake1()
{
struct Tag_timespec
{
time_t tv_sec; /*second*/
long tv_nsec; /**/
}current_time; clock_gettime(CLOCK_REALTIME,(timespec*) &(current_time));
printf("@@In time:%ld",current_time.tv_nsec);
printf("The mutual semphore will be taken now!\n"); semTake(semId,5000); /*take the mutual semphore*/ clock_gettime(CLOCK_REALTIME,(timespec*) &(current_time));
printf("##In time:%ld",current_time.tv_nsec);
printf("The mutual semphore was taken!\n");
}/*taskSemTake1*/ LOCAL void taskSemTake2()
{
struct Tag_timespec
{
time_t tv_sec; /*second*/
long tv_nsec; /**/
}current_time; clock_gettime(CLOCK_REALTIME,(timespec*) &(current_time));
printf("@@In time:%ld",current_time.tv_nsec);
printf("The mutual semphore will be taken now!\n"); semTake(semId,5000); /*take the mutual semphore*/ clock_gettime(CLOCK_REALTIME,(timespec*) &(current_time));
printf("##In time:%ld",current_time.tv_nsec);
printf("The mutual semphore was taken!\n");
}/*taskSemTake1*/ LOCAL void taskSemTake3()
{
struct Tag_timespec
{
time_t tv_sec; /*second*/
long tv_nsec; /**/
}current_time; clock_gettime(CLOCK_REALTIME,(timespec*) &(current_time));
printf("@@In time:%ld",current_time.tv_nsec);
printf("The mutual semphore will be taken now!\n"); semTake(semId,5000); /*take the mutual semphore*/ clock_gettime(CLOCK_REALTIME,(timespec*) &(current_time));
printf("##In time:%ld",current_time.tv_nsec);
printf("The mutual semphore was taken!\n");
}/*taskSemTake1*/ LOCAL void taskSemGive1()
{
STATUS ret; struct Tag_timespec
{
time_t tv_sec; /*second*/
long tv_nsec; /**/
}current_time; semGive(semId); /*take the mutual semphore*/
ret=semGive(semId); /*take the mutual semphore*/
if(ret==ERROR)
{
printf("Can't release the semphore");
} clock_gettime(CLOCK_REALTIME,(timespec*) &(current_time));
printf("##In time:%ld",current_time.tv_nsec);
printf("The mutual semphore has been given just now!\n");
}/*taskSemTake1*/ LOCAL void taskSemGive2()
{
STATUS ret; struct Tag_timespec
{
time_t tv_sec; /*second*/
long tv_nsec; /**/
}current_time; ret=semGive(semId); /*take the mutual semphore*/
if(ret==ERROR)
{
printf("Can't release the semphore");
} clock_gettime(CLOCK_REALTIME,(timespec*) &(current_time));
printf("##In time:%ld",current_time.tv_nsec);
printf("The mutual semphore has been given just now!\n");
}/*taskSemTake1*/ int createTsemCreate()
{
taskSemCreateId=taskSpawn("tCreateSem",100,VX_SUPERVISOR_MODE,4000,(FUNCPTR)taskSemCreate,0,0,0,0,0,0,0,0,0,0);
if(taskSemCreateId==ERROR)
{
printf("ERROR occurs in creating taskSemCreate!!!!!\n");
return 0;
}
return 1;
} int createTsemTake(int iteration)
{
if(iteration==1)
{
taskSemTake1Id=taskSpawn("tsemTake",100,VX_SUPERVISOR_MODE,4000,(FUNCPTR)taskSemTake1,0,0,0,0,0,0,0,0,0,0);
if(taskSemTake1Id==ERROR)
{
printf("ERROR occurs in creating taskSemTake1!!!!!\n");
return 0;
}
return 1;
}
else if(iteration==2)
{
taskSemTake2Id=taskSpawn("tsemTake",100,VX_SUPERVISOR_MODE,4000,(FUNCPTR)taskSemTake2,0,0,0,0,0,0,0,0,0,0);
if(taskSemTake2Id==ERROR)
{
printf("ERROR occurs in creating taskSemTake2!!!!!\n");
return 0;
}
return 1;
}
else if(iteration==3)
{
taskSemTake3Id=taskSpawn("tSemTake",100,VX_SUPERVISOR_MODE,4000,(FUNCPTR)taskSemTake3,0,0,0,0,0,0,0,0,0,0);
if(taskSemTake2Id==ERROR)
{
printf("ERROR occurs in creating taskSemTake3!!!!!\n");
return 0;
}
return 1;
}
else
{
printf("The parameter is error!!\n");
return 0;
}
} int createTsemGive(int iteration)
{
if(iteration==1)
{
taskSemGive1Id=taskSpawn("tSemGive",100,VX_SUPERVISOR_MODE,4000,(FUNCPTR)taskSemGive1,0,0,0,0,0,0,0,0,0,0);
if(taskSemGive1Id==ERROR)
{
printf("ERROR occurs in creating taskSemGive1!!!!!\n");
return 0;
}
return 1;
}
else if(iteration==2)
{
taskSemGive2Id=taskSpawn("tsemGive",100,VX_SUPERVISOR_MODE,4000,(FUNCPTR)taskSemGive2,0,0,0,0,0,0,0,0,0,0);
if(taskSemGive2Id==ERROR)
{
printf("ERROR occurs in creating taskSemGive!!!!!\n");
return 0;
}
return 1;
}
else
{
printf("The parameter is error!!\n");
return 0;
}
} [align=right][color=#000066][此贴子已经被作者于2004-7-6 11:12:42编辑过][/color][/align]