北理工操作系統(tǒng)實驗二讀者寫者問題(編輯修改稿)
2025-04-20 23:07 本頁面
【文章內(nèi)容簡介】 讀者、寫者的信息 inFile thread_info[n_thread].serial。 inFile thread_info[n_thread].entity。 inFile thread_info[n_thread].delay。 inFile thread_info[n_thread ++ ].persist。 () 。 } n_thread。 for (int i = 0。 i (int) (n_thread)。 i ++) { if (thread_info[i].entity == READER || thread_info[i].entity == 39。R39。 ) { // 創(chuàng)建讀者線程 h_Thread[i] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) (RP_ReaderThread) , amp。thread_info[i] , 0, amp。thread_ID) 。 printf(讀者線程 %d 已創(chuàng)建.\n , thread_info[i].serial) 。 } else { // 創(chuàng)建寫者線程 h_Thread[i] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) (RP_WriterThread) , amp。thread_info[i] , 0, amp。thread_ID) 。 printf(寫者線程 %d 已創(chuàng)建.\n , thread_info[i].serial) 。 } } // 等待所有線程結(jié)束 wait_for_all = WaitForMultipleObjects(n_thread, h_Thread, TRUE, 1) 。 printf(所有讀者寫者均完成操作.\n ) 。}// 寫者優(yōu)先讀者線程// p: 讀者線程信息void WP_ReaderThread(void * p){ // 互斥變量 HANDLE h_Mutex1。 h_Mutex1 = OpenMutex(MUTEX_ALL_ACCESS, FALSE, mutex1 ) 。 HANDLE h_Mutex2。 h_Mutex2 = OpenMutex(MUTEX_ALL_ACCESS, FALSE, mutex2 ) 。 DWORD wait_for_mutex1。 // 等待互斥變量所有權(quán) DWORD wait_for_mutex2。 DWORD m_delay。 // 延遲時間 DWORD m_persist。 // 讀文件持續(xù)時間 int m_serial。 // 線程序號 // 從參數(shù)中獲得信息 m_serial = ( (ThreadInfo* ) (p) ) serial。 m_delay = (DWORD) ( ( (ThreadInfo* ) (p) ) delay * INTE_PER_SEC) 。 m_persist = (DWORD) ( ( (ThreadInfo* ) (p) ) persist * INTE_PER_SEC) 。 Sleep(m_delay) 。 // 延遲等待 printf(讀者線程 %d 發(fā)送讀文件請求.\n , m_serial) 。 wait_for_mutex1 = WaitForSingleObject(h_Mutex1, 1) 。 // 進入讀者臨界區(qū) EnterCriticalSection(amp。cs_Read) 。 // 阻塞互斥對象mutex2，保證對readcount的訪問、修改互斥 wait_for_mutex2 = WaitForSingleObject(h_Mutex2, 1) 。 // 修改讀者數(shù)目 readcount ++。 if (readcount == 1) { // 如果是第一個讀者，等待寫者寫完 EnterCriticalSection(amp。cs_Write) 。 } ReleaseMutex(h_Mutex2) 。 // 釋放互斥信號mutex2 // 讓其他讀者進入臨界區(qū) LeaveCriticalSection(amp。cs_Read) 。 ReleaseMutex(h_Mutex1) 。 // 讀文件 printf(讀者線程 %d 開始讀文件.\n , m_serial) 。 Sleep(m_persist) 。 // 退出線程 printf(讀者線程 %d 讀文件結(jié)束.\n , m_serial) 。 // 阻塞互斥對象mutex2，保證對readcount的訪問、修改互斥 wait_for_mutex2 = WaitForSingleObject(h_Mutex2, 1) 。 readcount 。 if (readcount =
范文總結(jié)相關(guān)推薦
鄂ICP備17016276號-1