色婷婷AⅤ一区二区三区|亚洲精品第一国产综合亚AV|久久精品官方网视频|日本28视频香蕉

          新聞中心

          EEPW首頁 > 嵌入式系統(tǒng) > 設(shè)計(jì)應(yīng)用 > 進(jìn)程間通信之:消息隊(duì)列

          進(jìn)程間通信之:消息隊(duì)列

          作者: 時(shí)間:2013-09-13 來源:網(wǎng)絡(luò) 收藏

          本文引用地址:http://cafeforensic.com/article/257123.htm

          表8.26列舉了msgctl()函數(shù)的語法要點(diǎn)。

          表8.26 msgctl()函數(shù)語法要點(diǎn)

          所需頭文件

          #includesys/types.h>

          #includesys/ipc.h>

          #includesys/shm.h>

          函數(shù)原型

          intmsgctl(intmsgqid,intcmd,structmsqid_ds*buf)

          函數(shù)傳入值

          msqid:的隊(duì)列ID

          cmd:

          命令參數(shù)

          IPC_STAT:讀取的數(shù)據(jù)結(jié)構(gòu)msqid_ds,并將其存儲(chǔ)在buf指定的地址中

          IPC_SET:設(shè)置的數(shù)據(jù)結(jié)構(gòu)msqid_ds中的ipc_perm域(IPC操作權(quán)限描述結(jié)構(gòu))值。這個(gè)值取自buf參數(shù)

          IPC_RMID:從系統(tǒng)內(nèi)核中刪除消息隊(duì)列

          buf:描述消息隊(duì)列的msgqid_ds結(jié)構(gòu)類型變量

          函數(shù)返回值

          成功:0

          出錯(cuò):-1

          3.使用實(shí)例

          這個(gè)實(shí)例體現(xiàn)了如何使用消息隊(duì)列進(jìn)行兩個(gè)進(jìn)程(發(fā)送端和接收端)之間的通信,包括消息隊(duì)列的創(chuàng)建、消息發(fā)送與讀取、消息隊(duì)列的撤消和刪除等多種操作。

          消息發(fā)送端進(jìn)程和消息接收端進(jìn)程之間不需要額外實(shí)現(xiàn)進(jìn)程之間的同步。在該實(shí)例中,發(fā)送端發(fā)送的消息類型設(shè)置為該進(jìn)程的進(jìn)程號(hào)(可以取其他值),因此接收端根據(jù)消息類型確定消息發(fā)送者的進(jìn)程號(hào)。注意這里使用了函數(shù)fotk(),它可以根據(jù)不同的路徑和關(guān)鍵字產(chǎn)生標(biāo)準(zhǔn)的key。以下是消息隊(duì)列發(fā)送端的代碼:

          /*msgsnd.c*/

          #includesys/types.h>

          #includesys/ipc.h>

          #includesys/msg.h>

          #includestdio.h>

          #includestdlib.h>

          #includeunistd.h>

          #includestring.h>

          #defineBUFFER_SIZE512

          structmessage

          {

          longmsg_type;

          charmsg_text[BUFFER_SIZE];

          };

          intmain()

          {

          intqid;

          key_tkey;

          structmessagemsg;

          /*根據(jù)不同的路徑和關(guān)鍵字產(chǎn)生標(biāo)準(zhǔn)的key*/

          if((key=ftok(.,'a'))==-1)

          {

          perror(ftok);

          exit(1);

          }

          /*創(chuàng)建消息隊(duì)列*/

          if((qid=(key,IPC_CREAT|0666))==-1)

          {

          perror();

          exit(1);

          }

          printf(Openqueue%dn,qid);

          while(1)

          {

          printf(Entersomemessagetothequeue:);

          if((fgets(msg.msg_text,BUFFER_SIZE,stdin))==NULL)

          {

          puts(nomessage);

          exit(1);

          }

          msg.msg_type=getpid();

          /*添加消息到消息隊(duì)列*/

          if((msgsnd(qid,msg,strlen(msg.msg_text),0))0)

          {

          perror(messageposted);

          exit(1);

          }

          if(strncmp(msg.msg_text,quit,4)==0)

          {

          break;

          }

          }

          exit(0);

          }

          linux操作系統(tǒng)文章專題:linux操作系統(tǒng)詳解(linux不再難懂)


          評(píng)論


          相關(guān)推薦

          技術(shù)專區(qū)

          關(guān)閉