#include??“windows.h“
#include??
#include??
#include??
#include??
#include??
#include??


#define??READER?‘R‘
#define??WRITER?‘W‘
#define??INTE_PER_SEC?1000
#define??MAX_THREAD_NUM?64
#define??MAX_FILE_NUM?32
#define??MAX_STR_LEN?32

int??readcount=0;
int??writecount=0;

CRITICAL_SECTION?RP_Write;
CRITICAL_SECTION?cs_Write;
CRITICAL_SECTION?cs_Read;

struct?ThreadInfo//?定義線程數據結構
{
	int?serial;//?線程序號
	char?entity;//?線程類別（判斷是讀者線程還是寫者線程）
	double?delay;//?線程延遲
	double?persist;//?線程讀寫操作持續時間
};
///////////////////////////////////////////////////////////////////////
//讀者優先--讀者線程
//p:讀者線程信息

void?RP_ReaderThread（void?*p）
{
??HANDLE?h_Mutex;
??h_Mutex=OpenMutex（MUTEX_ALL_ACCESSFALSE“mutex_for_readcount“）;

??DWORD?wait_for_mutex;//等待互斥變量所有權
??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?（“Reader?thread?%d?sents?the?reading?require.\n“m_serial）;
??wait_for_mutex=WaitForSingleobject（h_Mutex-1）;
??readcount++;
??if（readcount==1）
??{
	??EnterCriticalSection（&RP_Write）;
??}
??ReleaseMutex（h_Mutex）;
??printf（“Reader?thread?%d?begins?to?read?file.\n“m_serial）;
??Sleep（m_persist）;
??printf（“Reader?thread?%d?finished?reading?file.\n“m_serial）;
??wait_for_mutex=WaitForSingleobject（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;
??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（“Writer?thread?%d?sents?the?writing?require.\n“m_serial）;
???EnterCriticalSection（&RP_Write）;
???printf（“Writer?thread?%d?begins?to?write?the??file.\n“m_serial）;
???Sleep（m_persist）;
???printf（“Writer?thread?%d?finishing?writing?to?the?file.\n“m_serial）;
???LeaveCriticalSection（&RP_Write）;
}
/////////////////////////////////////////////////////////////////
//讀者優先處理函數
//file:文件名
void?ReaderPriority（char?*file）
{
	DWORD?n_thread=0;?//?線程數目
	DWORD?thread_ID;//?線程ID
	DWORD?wait_for_all;//?等待所有線程結束
	HANDLE?h_Mutex;//?互斥對象
	h_Mutex=CreateMutex（NULLFALSE“mutex_for_readcount“）;

	HANDLE?h_Thread[MAX_THREAD_NUM];//?線程對象的數組
	ThreadInfo?thread_info[MAX_THREAD_NUM];
	readcount=0;
	InitializeCriticalSection（&RP_Write）;
	ifstream?inFile;
	inFile.open（file）;
	printf（“Reader?Priority:\n\n“）;
	while（inFile）//讀人每一個讀者、寫者的信息
	{
		inFile>>thread_info[n_thread].serial;
????????inFile>>thread_info[n_thread].entity;
????????inFile>>t