亚洲国产日韩欧美在线a乱码,国产精品路线1路线2路线,亚洲视频一区,精品国产自,www狠狠,国产情侣激情在线视频免费看,亚洲成年网站在线观看

基于C++的讀者與寫者問題read—write problem的實(shí)現(xiàn)(一

時間:2023-03-07 11:02:41 計算機(jī)畢業(yè)論文 我要投稿
  • 相關(guān)推薦

基于C++的讀者與寫者問題read—write problem的實(shí)現(xiàn)(一)


基于C++的讀者與寫者問題的實(shí)現(xiàn) 1
1.設(shè)計題目與要求 1
2.總的設(shè)計思想及系統(tǒng)平臺、語言、工具等 1
2.1 設(shè)計思想 1
2.2 系統(tǒng)平臺,語言,工具 4
3.?dāng)?shù)據(jù)結(jié)構(gòu)與模塊說明(功能與流程圖) 4
3.1 功能實(shí)現(xiàn) 4
3.2 流程圖 6
4.源程序 7
4.1 .ReaderAndWriter.CPP   // 具體的實(shí)現(xiàn) 7
4.2.thread.dat //輔助的文件,但是必不可以少 15
5.運(yùn)行結(jié)果與運(yùn)行情況 15
6.調(diào)試記錄 17
7.自我評析和總結(jié) 18

 

基于C++的讀者與寫者問題read—write problem的實(shí)現(xiàn)

1.設(shè)計題目與要求
     讀者寫者問題(read—write problem)是一個經(jīng)典的并發(fā)程序設(shè)計問題。有兩組并發(fā)進(jìn)程:讀者和寫者,共享一個問題F,要求:(1)允許多個讀者可同時對之執(zhí)行讀操作;(2)只允許一個寫者往文件中寫信息;(3)任一寫者在完成寫操作之前不允許其他讀者或者寫者工作;(4)寫者執(zhí)行寫操作前,應(yīng)讓已有的寫者和讀者全部退出。

2.總的設(shè)計思想及系統(tǒng)平臺、語言、工具等
2.1 設(shè)計思想
   根據(jù)題目要求,首先分析了以下4種可能發(fā)生的情況:
    第 1 種情況: 讀者的優(yōu)先權(quán)比寫者高,而且,不用調(diào)配。
 所有讀者的優(yōu)先權(quán)都比寫者的優(yōu)先權(quán)高,而且,不用調(diào)配。一個讀者需要等待的唯一情況是,一個寫者已經(jīng)占用了文件。一個寫者可以取得文件的條件是,沒有一個讀者處在等待狀態(tài)或正在讀文件。允許讀者們結(jié)盟,以便能長期占用文件,而禁止寫者的寫。
 第 2 種情況: 在一個讀者已經(jīng)占有了文件的時候,全體讀者的優(yōu)先權(quán)才比寫者高。
 在沒有任何一個讀者在讀文件時,讀者的優(yōu)先權(quán)和寫者的優(yōu)先權(quán)相同。相反,如果有一個讀者正在讀文件,則其余的各讀者都可以讀文件,而不管有多少寫者處在等待狀態(tài)。所有讀者都有權(quán)結(jié)盟,以便壟斷文件。
 第 3 種情況: 寫者的優(yōu)先權(quán)比讀者的優(yōu)先權(quán)高。
 在一個寫者提出要訪問文件時,就必須使其盡可能的得到文件,而且不用調(diào)配。也就是說,在出現(xiàn)這一請求時,占據(jù)著文件的各進(jìn)程都被執(zhí)行完以后,寫者可以立即得到文件。因此,在文件已為一寫者請求之后到來的那些讀者都必須等待,盡管某些讀者正在應(yīng)用文件,也是如此。所有寫者可以結(jié)盟,以便能長期禁止讀者的讀。
 第 4 種情況: 所有寫者的和所有讀者有相同的優(yōu)先權(quán)高,哪一類都不會有比另一類更高的優(yōu)先權(quán)。
 如果一個讀者正在應(yīng)用文件,則在一個寫者請求文件之前到來的全體讀者,都能讀文件,而之后到來的讀者或?qū)懻,則要等待,不必區(qū)分他們屬于哪一類進(jìn)程。如果一個寫者正在寫文件,則所有新到來的請求都必須等待。在這一寫者寫完之后,它就要喚醒處在等待隊列中的排在第一個位置的進(jìn)程。如果此時有幾個讀者連續(xù)排在等待隊列中的最前面各位置上,則它們可以同時去讀文件。
 最后為了簡化問題,將其分為兩種主要情況:
(1)讀者優(yōu)先:
    如果沒有寫者正在操作,則讀者不需要等待,用一個整型變量readcount記錄當(dāng)前的讀者數(shù)目,用于確定是否釋放寫者線程,(當(dāng)readcout=0 時,說明所有的讀者都已經(jīng)讀完,釋放一個寫者線程),每個 讀者開始讀之前都要修改readcount,為了互斥的實(shí)現(xiàn)對readcount 的修改,需要一個互斥對象Mutex來實(shí)現(xiàn)互斥。
    另外,為了實(shí)現(xiàn)寫-寫互斥,需要一個臨界區(qū)對象 write,當(dāng)寫者發(fā)出寫的請求時,必須先得到臨界區(qū)對象的所有權(quán)。通過這種方法,可以實(shí)現(xiàn)讀寫互斥,當(dāng)readcount=1 時,(即第一個讀者的到來時,),讀者線程也必須申請臨界區(qū)對象的所有權(quán).
 當(dāng)讀者擁有臨界區(qū)的所有權(quán),寫者都阻塞在臨界區(qū)對象write上。當(dāng)寫者擁有臨界區(qū)對象所有權(quán)時,第一個判斷完readcount==1 后,其余的讀者由于等待對readcount的判斷,阻塞在Mutex上!
(2)寫者優(yōu)先:
 寫者優(yōu)先和讀者優(yōu)先有相同之處,不同的地方在:一旦有一個寫者到來時,應(yīng)該盡快讓寫者進(jìn)行寫,如果有一個寫者在等待,則新到的讀者操作不能讀操作,為此添加一個整型變量writecount,記錄寫者的數(shù)目,當(dāng)writecount=0時才可以釋放讀者進(jìn)行讀操作!
    為了實(shí)現(xiàn)對全局變量writecount的互斥訪問,設(shè)置了一個互斥對象Mutex3。
    為了實(shí)現(xiàn)寫者優(yōu)先,設(shè)置一個臨界區(qū)對象read,當(dāng)有寫者在寫或等待時,讀者必須阻塞在臨界區(qū)對象read上。
 讀者除了要一個全局變量readcount實(shí)現(xiàn)操作上的互斥外,還需要一個互斥對象對阻塞在read這一個過程實(shí)現(xiàn)互斥,這兩個互斥對象分別為mutex1和mutex2。
 測試數(shù)據(jù)文件格式:測試數(shù)據(jù)文件包括n 行測試數(shù)據(jù),分別描述創(chuàng)建的n 個線程是讀者還是寫者,以及讀寫操作的開始時間和持續(xù)時間。每行測試數(shù)據(jù)包括四個字段,各字段間用空格分隔。第一字段為一個正整數(shù),表示線程序號。第一字段表示相應(yīng)線程角色,R 表示讀者是,W 表示寫者。第二字段為一個正數(shù),表示讀寫操作的開始時間。線程創(chuàng)建后,延時相應(yīng)時間(單位為秒)后發(fā)出對共享資源的讀寫申請。第三字段為一個正數(shù),表示讀寫操作的持續(xù)時間。當(dāng)線程讀寫申請成功后,開始對共享資源的讀寫操作,該操作持續(xù)相應(yīng)時間后結(jié)束,并釋放共享資源。
 下面是一個測試數(shù)據(jù)文件的例子:
 1 R 3 5
 2 W 4 5
 3 R 5 2
 4 R 6 5
 5 W 5.1 3
 
 運(yùn)行結(jié)果顯示要求:要求在每個線程創(chuàng)建、發(fā)出讀寫操作申請、開始讀寫操作和結(jié)束讀寫操作時分別顯示一行提示信息,以確信所有處理都遵守相應(yīng)的讀寫操作限制。

2.2 系統(tǒng)平臺,語言,工具
 本次設(shè)計在WINDOWS XP操作系統(tǒng)平臺下,使用c++語言實(shí)現(xiàn)讀者與寫者問題。使用的軟件是Visual C++。
   

3.?dāng)?shù)據(jù)結(jié)構(gòu)與模塊說明(功能與流程圖)
 
3.1 功能實(shí)現(xiàn)
 相關(guān)API介紹:
 線程控制:
 CreateThread 完成線程創(chuàng)建,在調(diào)用進(jìn)程的地址空間上創(chuàng)建一個線程,以執(zhí)行指定的函數(shù);它的返回值為所創(chuàng)建線程的句柄。
 HANDLE CreateThread(
 LPSECURITY_ATTRIBUTES lpThreadAttributes, // SD
 DWORD dwStackSize, // initial stack size
 LPTHREAD_START_ROUTINElpStartAddress, // thread function
 LPVOID lpParameter, // thread argument
 DWORD dwCreationFlags, // creation option
 LPDWORD lpThreadId // thread identifier
 );
 ExitThread 用于結(jié)束當(dāng)前線程。
 VOID ExitThread(DWORD dwExitCode // exit code for this thread);
 Sleep 可在指定的時間內(nèi)掛起當(dāng)前線程。
 VOID Sleep(DWORD dwMilliseconds // sleep time);
 信號量控制:
 CreateMutex 創(chuàng)建一個互斥對象,返回對象句柄;
 HANDLE CreateMutex(
 LPSECURITY_ATTRIBUTES lpMutexAttributes, // SD
 BOOL bInitialOwner, // initial owner
 LPCTSTR lpName // object name);
 OpenMutex 打開并返回一個已存在的互斥對象句柄,用于后續(xù)訪問;
 HANDLE OpenMutex(
 DWORD dwDesiredAccess, // access
 BOOL bInheritHandle, // inheritance option
 LPCTSTR lpName // object name);
 ReleaseMutex 釋放對互斥對象的占用,使之成為可用。
 BOOL ReleaseMutex(
 HANDLE hMutex // handle to mutex);
 WaitForSingleObject 可在指定的時間內(nèi)等待指定對象為可用狀態(tài);
 DWORD WaitForSingleObject(
 HANDLE hHandle, // handle to object
 DWORD dwMilliseconds // time-out interval);
  測試文件數(shù)據(jù)結(jié)構(gòu)如下: 
  struct ThreadInfo
 {
 int serial;                      //線程序號
 char entity;                    //線程類別(判斷是讀者還是寫者線程)
 double delay;                    //線程延遲時間
 double persist;                  //線程讀寫操作時間
 };
void RP_ReaderThread(void *p)       // 讀者優(yōu)先情況下的讀者線程信息
void RP_WriterThread(void *p)       //讀者優(yōu)先情況下的寫者線程信息
void ReaderPriority(char *file)     //讀者優(yōu)先處理函數(shù)
void WP_ReaderThread(void *p)           //寫者優(yōu)先情況下的讀者線程信息
void WP_ReaderThread(void *p)          //寫者優(yōu)先情況下的寫者線程信息
void WriterPriority(char *file)     //寫者優(yōu)先處理函數(shù)
int main(int argc,char *argv     //主函數(shù),負(fù)責(zé)調(diào)用讀者或者寫者優(yōu)先函數(shù)
3.2 流程圖
    

                                    否
                                 
                       是

     是                                    否
                               否 
                 否                             是            否
                                是
                                                  是
                  否
         否

                   是

 

 

 
4.源程序
4.1 .ReaderAndWriter.CPP   // 具體的實(shí)現(xiàn)
 #include "windows.h"
 #include <conio.h>
 #include <stdlib.h>
 #include <fstream.h>
 #include <io.h>
 #include <string.h>
 #include <stdio.h>
 
 #define READER 'R'                   //讀者
 #define WRITER 'W'                   //寫者
 #define INTE_PER_SEC 1000            //每秒時鐘中斷的數(shù)目
 #define MAX_THREAD_NUM 64            //最大線程數(shù)
 #define MAX_FILE_NUM 32              //最大文件數(shù)目數(shù)
 #define MAX_STR_LEN 32               //字符串的長度

int readcount=0;                     //讀者數(shù)目
int writecount=0;                    //寫者數(shù)目
CRITICAL_SECTION RP_Write;           //臨界資源
CRITICAL_SECTION cs_Write;
CRITICAL_SECTION cs_Read;
struct ThreadInfo
{
 int serial;                      //線程序號
 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");
 
 
 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("Reader thread %d sents the reading require.\n",m_serial);
 
 //等待互斥信號,保證對ReadCount 的訪問,修改互斥
 wait_for_mutex=WaitForSingleObject(h_Mutex,-1);
 //讀者數(shù)目增加
 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);
 //等待互斥信號,保證對ReadCount的訪問,修改互斥
 wait_for_mutex=WaitForSingleObject(h_Mutex,-1);
 //讀者數(shù)目減少
  readcount--;
  if(readcount==0)
  {
   //如果所有的讀者讀完,喚醒寫者
   LeaveCriticalSection(&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("Write thread %d sents the writing require.\n",m_serial);
 //等待資源
 EnterCriticalSection(&RP_Write);
 //寫文件
 printf("Writer thread %d begins to write to the file.\n",m_serial);
 Sleep(m_persist);

 //退出線程
printf("Write thread %d finished writing to the file.\n",m_serial);
 //釋放資源
 LeaveCriticalSection(&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");

 //線程對象的數(shù)組
 HANDLE h_Thread[MAX_THREAD_NUM];
 ThreadInfo thread_info[MAX_THREAD_NUM];

 readcount=0;               //初始化readcount
 InitializeCriticalSection(&RP_Write);        //初始化臨界區(qū)
 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>>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')
  {
   //創(chuàng)建讀者進(jìn)程
   h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(RP_ReaderThread),&thread_info[i],0,&thread_ID);
  }
  else
  {
   //創(chuàng)建寫線程
   h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(RP_WriterThread),&thread_info[i],0,&thread_ID);
  }

 }
 //等待所有的線程結(jié)束
 wait_for_all=WaitForMultipleObjects(n_thread,h_Thread,TRUE,-1);
 printf("All reader and writer have finished operating.\n");
}

////////////////////////////////////////////////////////
//寫者優(yōu)先---讀者線程
//P:讀者線程信息


void WP_ReaderThread(void *p)
{

 //互斥變量
 HANDLE h_Mutex1;
 h_Mutex1=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex1");
 HANDLE h_Mutex2;
    h_Mutex2=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex2");

 DWORD wait_for_mutex1;            //等待互斥變量所有權(quán)
 DWORD wait_for_mutex2;
 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("Reader thread %d sents the reading require.\n",m_serial);
 wait_for_mutex1=WaitForSingleObject(h_Mutex1,-1);

 //讀者進(jìn)去臨界區(qū)
 EnterCriticalSection(&cs_Read);

 //阻塞互斥對象Mutex2,保證對readCount的訪問和修改互斥
  wait_for_mutex2=WaitForSingleObject(h_Mutex2,-1);
  //修改讀者的數(shù)目
  readcount++;
  if(readcount==1)
  {
   // 如果是第1個讀者,等待寫者寫完
   EnterCriticalSection(&cs_Write);
  }
  ReleaseMutex(h_Mutex2);// 釋放互斥信號 Mutex2
  //讓其他讀者進(jìn)去臨界區(qū)
  LeaveCriticalSection(&cs_Read);
  ReleaseMutex(h_Mutex1);
  //讀文件
  printf("Reader thread %d begins to read file.\n",m_serial);
  Sleep(m_persist);

  //退出線程
   printf("Reader thread %d finished reading  file.\n",m_serial);
   //阻塞互斥對象Mutex2,保證對readcount的訪問,修改互斥
   wait_for_mutex2=WaitForSingleObject(h_Mutex2,-1);
   readcount--;
   if(readcount==0)
   {
    //最后一個讀者,喚醒寫者
    LeaveCriticalSection(&cs_Write);
   }
   ReleaseMutex(h_Mutex2);  //釋放互斥信號
}
///////////////////////////////////////////
//寫者優(yōu)先---寫者線程
//P:寫者線程信息


void WP_WriterThread(void *p)
{
 DWORD wait_for_mutex3;            //互斥變量
 DWORD m_delay;                   //延遲時間
 DWORD m_persist;                 //讀文件持續(xù)時間
 int m_serial;                    //線程序號

 HANDLE h_Mutex3;
 h_Mutex3=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex3");

 //從參數(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("Writer thread %d sents the reading require.\n",m_serial);
 wait_for_mutex3=WaitForSingleObject(h_Mutex3,-1);
 writecount++;               //修改寫者數(shù)目
 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);
}
/////////////////////////////////////////////
//寫者優(yōu)先處理函數(shù)
// 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')
  {
   //創(chuàng)建讀者進(jìn)程
 h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(WP_ReaderThread),&thread_info[i],0,&thread_ID);
  }
  else
  {
   //創(chuàng)建寫線程
   h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(WP_WriterThread),&thread_info[i],0,&thread_ID);
  }

 }
 //等待所有的線程結(jié)束
 wait_for_all=WaitForMultipleObjects(n_thread,h_Thread,TRUE,-1);
 printf("All reader and writer have finished operating.\n");
}

/////////////////////////////////////////////////////
//主函數(shù)
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;
}

4.2.thread.dat //輔助的文件,但是必不可以少
 
 1  r   3  5
 2  w   4  5
 3  r   5   2
 4  r   6   5
 5  w   5.1  3
 


5.運(yùn)行結(jié)果與運(yùn)行情況
   對源程序進(jìn)行編譯,鏈接后,執(zhí)行程序:

 
 當(dāng)選擇1 Reader Priority 時,程序運(yùn)行結(jié)果如下:
 

 

按任意建后會到主界面,然后選擇2.Writer Priority 后,程序運(yùn)行結(jié)果如下:
   

 

6.調(diào)試記錄
 在編程過程中,沒有設(shè)置計數(shù)器來存儲讀者數(shù)目,結(jié)果在程序運(yùn)行時,產(chǎn)生了讀者與讀者的互斥。之后通過翻閱資料,了解了需要加入計數(shù)器來控制讀者與讀者之間的同等優(yōu)先,同時也用于控制寫者進(jìn)程的釋放,既當(dāng)計數(shù)器為0的時候,允許寫進(jìn)程訪問文件。
 在加入計數(shù)器后,重新編寫程序,就解決了以上問題。當(dāng)程序通過編譯鏈接之后,運(yùn)行程序,得到了正確的結(jié)果。然后修改文件thread.dat中的參數(shù):
1 R 3 4
2 R 4 3
3 W 4 5
 重新對程序進(jìn)行測試,分別選擇讀者優(yōu)先和寫者優(yōu)先,結(jié)果正確。
 最后修改文件thread.dat中的參數(shù),使用更多的讀寫請求:
1 W 2 5
2 R 3 4
3 W 5 3
4 R 6 5
5 R 7 4
6 W 9 5
7 R 11 4
8 R 14 5
9 W 17 6
10 R 20 5
   運(yùn)行程序的結(jié)果都正確。讀者寫者問題程序設(shè)計成功。
7.自我評析和總結(jié)
 課程設(shè)計是培養(yǎng)學(xué)生綜合運(yùn)用所學(xué)知識,發(fā)現(xiàn),提出,分析和解決實(shí)際問題,鍛煉實(shí)踐能力的重要環(huán)節(jié),是對學(xué)生實(shí)際工作能力的具體訓(xùn)練和考察過程.
 操作系統(tǒng)的出現(xiàn),使用和發(fā)展是近四十余年來計算機(jī)軟件的一個重大進(jìn)展。操作系統(tǒng)中引入并發(fā)程序設(shè)計技術(shù)后,程序的執(zhí)行不在是順序的。一個程序未執(zhí)行完而另一個程序便已開始執(zhí)行,程序挖補(bǔ)的順序特性消失,程序與計算不再一一對應(yīng),所以操作系統(tǒng)引進(jìn)進(jìn)程概念來描述這種變化。讀者與寫者問題就是一個經(jīng)典的并發(fā)程序設(shè)計問題。
 在開始做課程設(shè)計時,我首先翻閱了很多關(guān)于并發(fā)程序的書籍,找到了基本的解決方法,那就是信號量的使用。記錄型信號量和PV操作不僅可以解決進(jìn)程的互斥,而且更是實(shí)現(xiàn)進(jìn)程同步的有力工具。但是發(fā)現(xiàn)光有信號量是解決不了讀者和寫者問題,因為所有讀進(jìn)程不會相互互斥。所以程序?qū)π盘柫窟M(jìn)行了改進(jìn)。引入了一個計數(shù)器,記錄讀者的數(shù)目,控制是否釋放寫者進(jìn)程。
 做到這些,思路已經(jīng)基本確定。在變成過程中查閱了許多書籍,也對WINDOWS下的一些API做了些了解。
 接近2周的課程設(shè)計,讓我學(xué)到了不少東西,從開始的查閱書籍,確定思路,到最后的編寫程序和調(diào)試。設(shè)計過程中遇到了不少困難,但在同學(xué)和老師的幫助下都一一克服了。
 總之,每一次課程設(shè)計不僅是我們學(xué)習(xí)的好機(jī)會,而且是我們鍛煉實(shí)際動手能力的平臺,雖然有難度的東西總會讓人很抵觸,比如在課設(shè)過程中有很多郁悶的時候,一個小小的錯誤一不小心就花去了自己一上午的時間,所以在這個過程中能夠磨練人的意志與耐心,最后感謝老師的指導(dǎo)與監(jiān)督,使我在課程設(shè)計過程中學(xué)到了書本是學(xué)不到的知識,同時也對操作系統(tǒng)有了更深刻的認(rèn)識,為以后的學(xué)習(xí)打下了堅實(shí)的基礎(chǔ)。

【基于C++的讀者與寫者問題read—write problem的實(shí)現(xiàn)(一】相關(guān)文章:

基于minigui的網(wǎng)真機(jī)界面的實(shí)現(xiàn)08-05

Managing the problem formulation process: guidelines for tea05-30

試論基于民商法視域下的信用卡若干法律問題05-28

淺論世界遺產(chǎn)地旅游消費(fèi)者教育問題06-10

基于分組技術(shù)的下一代光傳送網(wǎng)05-29

試析基于勝任素質(zhì)的薪酬模式構(gòu)建01-03

基于戰(zhàn)略治理的企業(yè)環(huán)境風(fēng)險研究08-28

一個嵌入式系統(tǒng)的Petri網(wǎng)模型與CPLD實(shí)現(xiàn)05-29

都市頻道制作網(wǎng)的設(shè)計與實(shí)現(xiàn)05-29

基于軟交換的固網(wǎng)智能化05-11