todaaa第3章--進(jìn)程同步與通信-資料下載頁
2025-07-24 15:29本頁面
【正文】 unt == 0) cwait(notempty)。 x = buffer[nextout]。 nextout = (nextout + 1) % n。 count = count 1。 csignal(notfull)。 } {/*管程體 */ nextin = 0。 nextout = 0。 count = 0。 /*變量初始化 */ } void producer() /* 生產(chǎn)者進(jìn)程 */ { char x。 while (true) { produce an char in x。 (x)。 } } void consumer() /* 消費(fèi)者進(jìn)程 */ { char x。 while (true) { (x)。 consume an x。 } } 利用 管程 解決生產(chǎn)者 消費(fèi)者問題 ● 進(jìn)程通信 信號燈作為進(jìn)程同步和互斥工具是卓有成效的。但作為通信工具就不夠理想。其原因?yàn)椋? ● 效率低 ——一次只傳一條消息。 ● 通信對用戶不透明。 因此必須引入高級通信工具，解決進(jìn)程之間大量的信息傳遞問題 進(jìn)程通信的類型 ● 共享存儲器系統(tǒng) ● 消息傳遞系統(tǒng) ● 直接通信方式 ● 間接通信方式 ● 管道通信 進(jìn)程通信中的幾個(gè)問題 ● 通信鏈路的建立方式 ● 顯示建立鏈路 ● 隱式建立鏈路 ● 通信方向 ● 通信鏈路連接方式 ● 通信鏈路的容量 ● 數(shù)據(jù)格式 ● 同步方式 ● 阻塞方式 ● 不阻塞方式 next:0mqsmmutexreceive(b)send(B,a)size:5sender:Atext:Hellosize:5sender:Atext:Hellosize:5sender:Atext:HelloPCB(B) 進(jìn)程A 進(jìn)程B發(fā)送區(qū) 接收區(qū)ab消息緩沖隊(duì)列 示意圖 消息緩沖隊(duì)列 數(shù)據(jù)結(jié)構(gòu)定義 //消息緩沖區(qū)定義 struct message_buffer { char sender[30]。 /*發(fā)送進(jìn)程標(biāo)識符 */ int size。 /*消息長度 */ char text[200]。 /*消息正文 */ struct message_buffer *next。 //指向下一個(gè)消息緩沖區(qū)的指針 } //PCB中有關(guān)通信的數(shù)據(jù)項(xiàng) struct process_control { struct message_buffer *mq。 /*消息隊(duì)列隊(duì)首指針 */ semaphore mutex=1。 /*消息隊(duì)列互斥信號量，初值為 1*/ semaphore sm=0。 /*消息隊(duì)列同步信號量，記錄消息的個(gè)數(shù) .初值為 0*/ } //發(fā)送原語 char receiver[30]。 struct message_buffer a。 void send(receiver, a) { struct message_buffer i。 struct process_control j。 getbuf(, i)。 /*發(fā)送區(qū) a消息的長度申請一緩沖區(qū) i*/ = 。 = 。 = 。 = NULL。 getid(PCB_set, receiver, j)。 /*獲得接收進(jìn)程的進(jìn)程標(biāo)識符 j*/ P()。 Insert(, i)。 /*將消息緩沖區(qū) i掛到的消息隊(duì)列 */ V()。 V()。 } 消息緩沖隊(duì)列 發(fā)送原語 消息緩沖隊(duì)列 接收原語 struct message_buffer b。 void receive(b) { struct message_buffer i。 struct process_control j。 j = internal_name()。 /*接收進(jìn)程的內(nèi)部標(biāo)識符 */ P()。 P()。 remove(, i)。 /*從消息隊(duì)列中摘下第一個(gè)消息緩沖區(qū) */ V()。 = 。 = 。 = 。 } 客戶 —服務(wù)器系統(tǒng)通信 常用的通信方式： ● 命名管道 ● 套接字 ● 遠(yuǎn)程過程調(diào)用 ● —— P84/ ● 1 ● 4 ● 5 ● 6 作業(yè)
研究報(bào)告相關(guān)推薦
鄂ICP備17016276號-1