Chinaunix首页 | 论坛 | 博客
  • 博客访问: 7724440
  • 博文数量: 961
  • 博客积分: 15795
  • 博客等级: 上将
  • 技术积分: 16612
  • 用 户 组: 普通用户
  • 注册时间: 2010-08-07 14:23
文章分类

全部博文(961)

文章存档

2016年(1)

2015年(61)

2014年(41)

2013年(51)

2012年(235)

2011年(391)

2010年(181)

分类: C/C++

2010-12-09 13:16:16

#include

#include

#include

#include

#include

 

#include

#include

#include

 

struct my_msg_st

{

    long int my_msg_type;

      char some_text[BUFSIZ];

};

 

int main(void)

{

    int running=1;

      int msgid;

      struct my_msg_st some_data;

      long int msg_to_receive=0;

 

      /*创建消息队列*/

      msgid=msgget((key_t)1234,0666 | IPC_CREAT);

      if(msgid==-1)

      {

          fprintf(stderr,"msgget failed with error: %d\n",errno);

           exit(EXIT_FAILURE);

      }

     

      /*循环从消息队列中接收消息*/

      while(running)

      {

           /*读取消息*/

          if(msgrcv(msgid,(void *)&some_data,BUFSIZ,msg_to_receive,0)==-1)

           {

               fprintf(stderr,"msgrcv failed with error: %d\n",errno);

                 exit(EXIT_FAILURE);

           }

 

           printf("You wrote: %s",some_data.some_text);

 

           /*接收到的消息为“end”时结束循环*/

           if(strncmp(some_data.some_text,"end",3)==0)

           {

               running=0;

            }

      }

 

      /*从系统内核中移走消息队列*/

      if(msgctl(msgid,IPC_RMID,0)==-1)

      {

          fprintf(stderr,"msgctl(IPC_RMID) failed\n");

           exit(EXIT_FAILURE);

      }

      exit(EXIT_SUCCESS);

}

 

 

#include

#include

#include

#include

#include

#include

#include

#include

#define MAX_TEXT 512

 

struct my_msg_st

{

    long int my_msg_type;

      char some_text[MAX_TEXT];

};

 

int main(void)

{

    int running=1;

      struct my_msg_st some_data;

      int msgid;

      char buffer[BUFSIZ];

 

      /*创建消息队列*/

      msgid=msgget((key_t)1234,0666 | IPC_CREAT);

      if(msgid==-1)

      {

          fprintf(stderr,"msgget failed with error:%d\n",errno);

           exit(EXIT_FAILURE);

    }

 

      /*循环向消息队列中添加消息*/

      while(running)

      {

          printf("Enter some text:");

           fgets(buffer,BUFSIZ,stdin);

           some_data.my_msg_type=1;

           strcpy(some_data.some_text,buffer);

 

           /*添加消息*/

           if(msgsnd(msgid,(void *)&some_data,MAX_TEXT,0)==-1)

           {

               fprintf(stderr,"msgsed failed\n");

                 exit(EXIT_FAILURE);

           }

 

           /*用户输入的为“end”时结束循环*/

           if(strncmp(buffer,"end",3)==0)

           {

               running=0;

           }

      }

      exit(EXIT_SUCCESS);

}

 

 

阅读(1996) | 评论(0) | 转发(3) |
0

上一篇:共享内存

下一篇:线程创建

给主人留下些什么吧!~~