操作系統(tǒng)實驗二mutex-資料下載頁
2025-07-07 14:17本頁面
【正文】 t(amp。Full)。 sem_wait(amp。Mutex)。 coutConsumer id。 consume()。 sem_post(amp。Empty)。 sem_post(amp。Mutex)。 } return 0。}int main(){ int prod_num,cons_num,runtime。 coutinput producer and consumer number:。 cinprod_numcons_num。 coutinput how long main sleep:。 cinruntime。 pthread_t *h_producer = new pthread_t[prod_num]。 pthread_t *h_consumer = new pthread_t[cons_num]。 sem_init(amp。Empty,0,M)。 sem_init(amp。Full,0,0)。 sem_init(amp。Mutex,0,1)。 int i。 for(i=0。iprod_num。i++) { pthread_create(amp。h_producer[i], NULL,producer, NULL)。 } for(i=0。icons_num。i++) { pthread_create(amp。h_consumer[i], NULL,consumer, NULL)。 } sleep(runtime)。}程序運(yùn)行時的初值和運(yùn)行結(jié)果消費(fèi)者：10 生產(chǎn)者：10 運(yùn)行時間：60000ms實驗體會：這次實驗主要是通過實現(xiàn)生產(chǎn)者、消費(fèi)者問題，掌握同步機(jī)制的技巧。以前在java中使用過多線程，也遇到過多線程訪問導(dǎo)致的數(shù)據(jù)失真，這次在操作系統(tǒng)平臺上實現(xiàn)同步，從底層了解了同步的機(jī)制。Win32和pthread都是使用Semaphore這樣一個信號量，當(dāng)有人占用這樣一個信號量時，其他人都需要等待直到這一信號量被釋放。同時在考慮問題時，還要注意哪些地方需要信號量：臨界區(qū)需要mutex(互斥鎖)；一個線程完成動作告知另一個線程(生產(chǎn)完畢可以消費(fèi))也需要semaphore。
外語相關(guān)推薦
鄂ICP備17016276號-1