计算机操作系统实验程序仅供参考

1、#include stdafx.h #include windows.h #include #include #include #include #include #include #define READER R#define WRITER W/读者/写者/每秒时钟中断的数目/最大线程数/最大文件数目数/字符串的长度#defineE_PER_SEC 1000#define MAX_THREAD_NUM 64#define MAX_FILE_NUM 32#define MAX_STR_LEN 32readcount=0;/读者数目writecount=0;/写者数目CRITICAL_SECTI

2、ON RP_Write;CRITICAL_SECTION cs_Write; CRITICAL_SECTION cs_Read;/临界资源struct ThreadInfoserial; char entity; double delay;double persist;/线程序号/线程类别(判断是读者还是写者线程)/线程延迟时间/线程读写操作时间/读者优先-读者线程/P：读者线程信息void RP_ReaderThread(void *p)/互斥变量 HANDLE h_Mutex;h_Mutex=OpenMutex(MUTEX_ALL_ACS,FALSE,mutex_for_readcount

3、);DWORD wait_for_mutex;DWORD m_delay;/等待互斥变量所/延迟时间DWORD m_persist;m_serial;/读文件持续时间/线程序号/从参数中获得信息m_serial=(ThreadInfo*)(p)-serial ; m_delay=(DWORD)(ThreadInfo*)(p)-delay *E_PER_SEC);m_persist=(DWORD)(ThreadInfo*)(p)-persist *E_PER_SEC);Sleep(m_delay);/延迟等待pf(读线程 %d 发出读请求.n,m_serial);/等待互斥信号,保证对 Read

4、Count 的,修改互斥wait_for_mutex=WaitForSingleObject(h_Mutex,-1);/读者数目增加readcount+; if(readcount=1)/第一个读者,等待资源EnterCriticalSection(&RP_Write);ReleaseMutex(h_Mutex);/读文件/互斥信号pf(读线程 %d 开始读文件.n,m_serial);Sleep(m_persist);/退出线程pf(读线程 %d 结束读文件.n,m_serial);/等待互斥信号,保证对 ReadCount 的,修改互斥wait_for_mutex=WaitForSingl

5、eObject(h_Mutex,-1);/读者数目减少 readcount-; if(readcount=0)/如果所有的读者读完,唤醒写者 LeaveCriticalSection(&RP_Write);ReleaseMutex(h_Mutex);/互斥信号/读者优先-写者线程/P：写者线程信息void RP_WriterThread(void *p)DWORD m_delay; DWORD m_persist;m_serial;/延迟时间/写文件持续时间/线程序号/从参数中获得信息 m_serial=(ThreadInfo*)(p)-serial ; m_delay=(DWORD)(Thr

6、eadInfo*)(p)-delay * m_persist=(DWORD)(ThreadInfo*)(p)-persist *Sleep(m_delay);E_PER_SEC);E_PER_SEC);pf(写线程 %d 发出写请求*.n,m_serial);/等待资源EnterCriticalSection(&RP_Write);/写文件pf(写线程 %d 开始写文件.n,m_serial);Sleep(m_persist);/退出线程pf(写线程 %d 结束写文件.n,m_serial);/资源LeaveCriticalSection(&RP_Write);/读者优先处理函数void Re

7、adriority(char *file)DWORD n_thread=0; DWORD thread_ID;DWORD wait_for_all;/线程数目/线程 ID/等待所有线程结束/互斥对象 HANDLE h_Mutex;h_Mutex=CreateMutex(NULL,FALSE,mutex_for_readcount);/线程对象的数组HANDLE h_ThreadMAX_THREAD_NUM;ThreadInfo thread_infoMAX_THREAD_NUM;readcount=0;/初始化 readcountInitializeCriticalSection(&RP_Wr

8、ite); ifstream inFile;inFile.open (file);/初始化临界区pf(读者优先:nn);while(inFile)/读入每一个读者,写者的信息 inFilethread_infon_thread.serial; inFilethread_infon_thread.entity; inFilethread_infon_thread.delay; inFilethread_infon_thread+.persist; inFile.get();for(i=0;i()(n_thread);i+)if(thread_infoi.entity=READER|thread_

9、infoi.entity =r)/创建读者进程h_Threadi=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(RP_ReaderThread),&thr ead_infoi,0,&thread_ID);else/创建写线程h_Threadi=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(RP_WriterThread),&thre ad_infoi,0,&thread_ID);/等待所有的线程结束 wait_for_all=WaitForMultipleObjects(n_thread,h_Thread,TRUE,-1);/prf(A