讀者寫著問題系統(tǒng)設(shè)計書(編輯修改稿)
2025-04-22 03:56 本頁面
【文章內(nèi)容簡介】 程序號 char entity。 //線程類別(判斷是讀者還是寫者線程) double delay。 //線程延遲時間 double persist。 //線程讀寫操作時間}。///////////////////////////////////////////////////////////////////////////// 讀者優(yōu)先讀者線程//P:讀者線程信息void RP_ReaderThread(void *p){ //互斥變量 HANDLE h_Mutex。 h_Mutex=OpenMutex(MUTEX_ALL_ACCESS,FALSE,mutex_for_readcount)。 /*HANDLE OpenMutex( DWORD dwDesiredAccess, // access flag BOOL bInheritHandle, // inherit flag LPCTSTR lpName // pointer to mutexobject name )。*/ DWORD wait_for_mutex。 //等待互斥變量所有權(quán) 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)。 //等待互斥信號,保證對ReadCount 的訪問,修改互斥 wait_for_mutex=WaitForSingleObject(h_Mutex,1)。 //讀者數(shù)目增加 readcount++。 if(readcount==1) { //第一個讀者,等待資源 EnterCriticalSection(amp。RP_Write)。 } ReleaseMutex(h_Mutex)。 //釋放互斥信號 //讀文件 printf(讀者線程 %d 開始讀文件.\n,m_serial)。 Sleep(m_persist)。//線程掛起 //退出線程 printf(讀者線程 %d 完成讀文件.\n,m_serial)。 //等待互斥信號,保證對ReadCount的訪問,修改互斥 wait_for_mutex=WaitForSingleObject(h_Mutex,1)。 //讀者數(shù)目減少 readcount。 if(readcount==0) { //如果所有的讀者讀完,喚醒寫者 LeaveCriticalSection(amp。RP_Write)。 } ReleaseMutex(h_Mutex)。 //釋放互斥信號}////////////////////////////////////////////////////////////////P:寫者線程信息void RP_WriterThread(void *p){ 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)。 //等待資源 EnterCriticalSection(amp。RP_Write)。 //寫文件 printf(寫者線程 %d 開始寫文件.\n,m_serial)。 Sleep(m_persist)。 //退出線程 printf(寫者線程 %d 完成寫文件.\n,m_serial)。 //釋放資源 LeaveCriticalSection(amp。RP_Write)。}////////////////////////////////////////////////////////////////讀者優(yōu)先處理函數(shù)//file:文件名void ReaderPriority(char *file){ DWORD n_thread=0。 //線程數(shù)目 DWORD thread_ID。 //線程ID DWORD wait_for_all。 //等待所有線程結(jié)束 //互斥對象 HANDLE h_Mutex。 h_Mutex=CreateMutex(NULL,FALSE,mutex_for_readcount)。 /*HANDLE CreateMutex( LPSECURITY_ATTRIBUTES lpMutexAttributes, // pointer to security attributes BOOL bInitialOwner, // flag for initial ownership LPCTSTR lpName // pointer to mutexobject name )。*/ //線程對象的數(shù)組 HANDLE h_Thread[MAX_THREAD_NUM]。 ThreadInfo thread_info[MAX_THREAD_NUM]。
規(guī)章制度相關(guān)推薦
鄂ICP備17016276號-1