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