第4章進(jìn)程間通信3-文庫(kù)吧
2025-08-25 16:03 本頁(yè)面
【正文】 tructure for each present queue on the system */ struct msg_queue { struct kern_ipc_perm q_perm。 time_t q_stime。 /* last msgsnd time */ time_t q_rtime。 /* last msgrcv time */ time_t q_ctime。 /* last change time */ unsigned long q_cbytes。 /* current number of bytes on queue */ unsigned long q_qnum。 /* number of messages in queue */ unsigned long q_qbytes。 /* max number of bytes on queue */ pid_t q_lspid。 /* pid of last msgsnd */ pid_t q_lrpid。 /* last receive pid */ struct list_head q_messages。 struct list_head q_receivers。 struct list_head q_senders。 }。 2020/11/4 操作系統(tǒng)與實(shí)驗(yàn) 第 4章 2 6 3. Linux消息緩沖通信數(shù)據(jù)結(jié)構(gòu)之間的關(guān)系 msg_queue 發(fā)送進(jìn)程 pid 接收進(jìn)程 pid …… msg_msg *next msg_msg *next msgbuf msgbuf …… …… …… …… i ker_ipc_perm key …… q_messages q_receivers q_sanders 圖 給定 key值的消息隊(duì)列 2020/11/4 操作系統(tǒng)與實(shí)驗(yàn) 第 4章 2 7 發(fā)送消息原語(yǔ)與接收消息原語(yǔ)的同步互斥算法描述如下： /*發(fā)送消息原語(yǔ) */ send() { P(s2)。 P(mutex)； 將消息緩沖區(qū) msgbuf掛到消息隊(duì)列； V(mutex)； V(s1)； } /*接收消息原語(yǔ) */ receive() { P(s1)； P(mutex)； 從消息隊(duì)列取消息緩沖區(qū) msgbuf； V(mutex)； V(s2) } /*mutex 為互斥信號(hào)量， s1表示消息隊(duì)列上是否有消息， s2表示消息隊(duì)列是否有空（允許長(zhǎng)度） */ int mutex= 1， s1=0， s2=n； 2020/11/4 操作系統(tǒng)與實(shí)驗(yàn) 第 4章 2 8 發(fā) 送 消 息有 接 收 進(jìn) 程 嗎 ?申 請(qǐng) 綬 沖 區(qū) ， 并 將 發(fā) 送的 內(nèi) 容 寫(xiě) 入 緩 沖 區(qū)接 收 進(jìn) 程 是 否 是 就 緒 態(tài) ？喚 醒 接 收 線 程返 回否是有無(wú)發(fā) 送 消 息 過(guò) 程接 收 消 息緩 沖 區(qū) 有 數(shù) 據(jù) 嗎 ？獲 取 緩 沖 區(qū) 中 的 數(shù) 據(jù)返 回有無(wú)接 收 消 息 過(guò) 程該 進(jìn) 程 變 為 阻 塞 態(tài)C P U 調(diào) 度4. 發(fā)送和接收消息執(zhí)行過(guò)程 2020/11/4 操作系統(tǒng)與實(shí)驗(yàn) 第 4章 2 9 發(fā)送消息進(jìn)程與接收消息進(jìn)程： 發(fā)送進(jìn)程在調(diào)用 send()原語(yǔ)之前 ， 先要作好以下準(zhǔn)備工作： ⑴ ． 申請(qǐng)一個(gè)消息緩沖區(qū) msgbuf； ⑵ ． 復(fù)制消息到緩沖區(qū) msgbuf； 接收進(jìn)程在接收到消息后要做以下善后處理： ⑴ ． 將消息緩沖區(qū) msgbuf中的消息復(fù)制到
教學(xué)課件相關(guān)推薦
鄂ICP備17016276號(hào)-1