main.c

嵌入式环境消息队列软件

#include "message.h"


int main(int argc, char *argv[])
{
	int				i,j;
	hMsgQId			id,id2,id3;
	int				length;
	unsigned char		params[3];  
	
	id=  MsgQCreate();//queue id=0
		
	id2=MsgQCreate();//queue id=1
	
	id3=MsgQCreate();//queue id=2
	
	for(i=0;i<5;i++)
	{
   	 	params[0]=i;
   		params[1]=i;
		params[2]=i;
    		MsgQSend(id,params,3);
	}
    
        for(i=0;i<6;i++)
	{
 	   	params[0]=i;
   		params[1]=i;
		params[2]=i;
   	 	MsgQSend(id2,params,3);
	}


	for(i=0;i<7;i++)
	{
 	   	params[0]=i;
   		params[1]=i;
		params[2]=i;
   	 	MsgQSend(id3,params,3);
	}
	MsgShowAll(id);
       MsgShowAll(id2);
	MsgShowAll(id3);
   
    
	for(j=0;j<3;j++)
	{
    		MsgQRecv(id,params,&length);
    		MsgShowSingle(params,length);
       }
    
       for(i=5;i<12;i++)
	{
    		params[0]=i;
   		params[1]=i;
		params[2]=i;
    		MsgQSend(id,params,3);
	}
       MsgShowAll(id);
     
    return 0;
}