/////////////////////////////////////////// //写者优先---写者线程 //P:写者线程信息     void WP_WriterThread(void *p) {        DWORD wait_for_mutex3;            //互斥变量        DWORD m_delay;                   //延迟时间        DWORD m_persist;                 //读文件持续时间        int m_serial;                    //线程序号          HANDLE h_Mutex3;        h_Mutex3=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex3");            //从参数中获得信息        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 reading require.\n",m_serial);        wait_for_mutex3=WaitForSingleObject(h_Mutex3,-1);        writecount++;               //修改写者数目        if(writecount==1)        {               EnterCriticalSection(&cs_Read);        }        ReleaseMutex(h_Mutex3);        EnterCriticalSection(&cs_Write);        printf("Writer thread %d begins to write to the file.\n",m_serial);        Sleep(m_persist);            printf("Writer thread %d finished writing to the file.\n",m_serial);        LeaveCriticalSection(&cs_Write);          wait_for_mutex3=WaitForSingleObject(h_Mutex3,-1);        writecount--;        if(writecount==0)        {               LeaveCriticalSection(&cs_Read);        } ReleaseMutex(h_Mutex3); } ///////////////////////////////////////////// //写者优先处理函数 // file:文件名   void WriterPriority(char * file) {        DWORD n_thread=0;        DWORD thread_ID;        DWORD wait_for_all;            HANDLE h_Mutex1;        h_Mutex1=CreateMutex(NULL,FALSE,"mutex1");        HANDLE h_Mutex2;        h_Mutex2=CreateMutex(NULL,FALSE,"mutex2");        HANDLE h_Mutex3;        h_Mutex3=CreateMutex(NULL,FALSE,"mutex3");        HANDLE h_Thread[MAX_THREAD_NUM];        ThreadInfo thread_info[MAX_THREAD_NUM];          readcount=0;        writecount=0;        InitializeCriticalSection(&cs_Write);        InitializeCriticalSection(&cs_Read);            ifstream inFile;        inFile.open (file);        printf("Writer priority:\n\n");        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)(WP_ReaderThread),&thread_info[i],0,&thread_ID);               }               else               {                      //创建写线程                      h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(WP_WriterThread),&thread_info[i],0,&thread_ID);               }          }        //等待所有的线程结束        wait_for_all=WaitForMultipleObjects(n_thread,h_Thread,TRUE,-1);        printf("All reader and writer have finished operating.\n"); }   ///////////////////////////////////////////////////// //主函数 int main(int argc,char *argv[]) {        char ch;        while(true)        {               printf("*************************************\n");               printf("   1.Reader Priority\n");               printf("   2.Writer Priority\n");               printf("   3.Exit to Windows\n");               printf("*************************************\n");               printf("Enter your choice(1,2,3): ");               do{                      ch=(char)_getch();               }while(ch!='1'&&ch!='2'&&ch!='3');               system("cls");               if(ch=='3')                      return 0;               else if(ch=='1')                      ReaderPriority("thread.dat");               else                      WriterPriority("thread.dat");               printf("\nPress Any Key to Coutinue:");               _getch();               system("cls"); }        return 0; }   二．thread.dat  的内容 1 r 3 5 2 w 4 5 3 r 5 2 4 r 6 5 5 w 5.1 3         第四部分：免责声明 1．  希望大家保持本文档的完整性。 2．  如果你要使用其中的代码，请著名：版权归原书所有。 3．  请不要想其他的人随便传递此文档，本人不担当任何后果。  

评论