loading
{
DWORD n_thread=0; //线程数目 DWORD thread_ID; //线程ID
DWORD wait_for_all; //等待所有线程结束 //互斥对象 HANDLE h_Mutex;
h_Mutex=CreateMutex(NULL,FALSE,\
//线程对象的数组
HANDLE h_Thread[MAX_THREAD_NUM]; ThreadInfo thread_info[MAX_THREAD_NUM];
readcount=0; // 初始化 readcount
InitializeCriticalSection(&RP_Write); //初始化临界区 ifstream inFile;
inFile.open(file); //打开文件 printf(\while(inFile) {
//读入每一个读者、写者的信息 inFile>>thread_info[n_thread].serial; inFile>>thread_info[n_thread].entity; inFile>>thread_info[n_thread].delay; inFile>>thread_info[n_thread++].persist; inFile.get( ); }
for(int i=0;i< (int)(n_thread);i++) {
if(thread_info[i].entity==READER || thread_info[i].entity=='R')
{
h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(RP_ReaderThread),&thread_info[i],0,&thread_ID); //创建读者线程
} else{
//创建写者线程
h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(RP_WriterThread),&thread_info[i],0,&thread_ID);
} }
//等待所有线程结束
wait_for_all=WaitForMultipleObjects(n_thread,h_Thread,TRUE,-1); printf(\}
/////////////////////////////////////////////////////////////////////////// // 写者优先--读者线程 //p：读者线程信息
void WP_ReaderThread(void* p) {
//互斥变量
HANDLE h_Mutex1;
h_Mutex1=OpenMutex(MUTEX_ALL_ACCESS,FALSE,\HANDLE h_Mutex2;
h_Mutex2=OpenMutex(MUTEX_ALL_ACCESS,FALSE,\
DWORD wait_for_mutex1; //等待互斥变量所有权
DWORD wait_for_mutex2;
DWORD m_delay; // 延迟时间 DWORD m_persist; // 读文件持续时间 int m_serial; //线程序号 //从参数中获得信息
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(\wait_for_mutex1= WaitForSingleObject(h_Mutex1,-1); //进入读者临界区
EnterCriticalSection(&cs_Read);
// 阻塞互斥对象mutex2，保证对readcount的访问、修改互斥 wait_for_mutex2= WaitForSingleObject(h_Mutex2,-1); //修改读者数目 readcount++; if(readcount==1) {
//如果是第一个读者，等待写者写完 EnterCriticalSection(&cs_Write); }
ReleaseMutex(h_Mutex2); //释放互斥信号mutex2 // 让其他读者进入临界区 LeaveCriticalSection(&cs_Write); ReleaseMutex(h_Mutex1); //读文件
printf(\Sleep(m_persist);
// 退出线程
printf(\// 阻塞互斥对象mutex2，保证对readcount的访问、修改互斥 wait_for_mutex2= WaitForSingleObject(h_Mutex2,-1); readcount--; if(readcount==0) {
// 最后一个读者，唤醒写者 LeaveCriticalSection(&cs_Write); }
ReleaseMutex(h_Mutex2); //释放互斥信号 }
/////////////////////////////////////////////////////////////////////////// // 写者优先--写者线程 //p：写者线程信息
void WP_WriterThread(void* p) {
DWORD m_delay; // 延迟时间 DWORD m_persist; // 写文件持续时间 int m_serial; //线程序号 DWORD wait_for_mutex3; //互斥对象
HANDLE h_Mutex3;
h_Mutex3= OpenMutex(MUTEX_ALL_ACCESS,FALSE,\
//从参数中获得信息
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); //延迟等待