实验3读者写者问题与进程同步文档格式.docx

1、除了上述四个规则外，不再规定读写的优先权，谁先等待谁就先使用文件。 实验步骤 算法分析1、错误的解法图3-1 错误的解法semaphore r_w_w=1;reader（）P（r_w_w）；读文件；V（r_w_w）；writer（）写文件；有同学认为，可以将文件视为临界资源，使用临界资源的代码就构成临界区，为了对临界区进行管理，只需设置一个互斥信号量r_w_w，读或者写之前执行P（r_w_w），之后执行V（r_w_w）即可，从而得到图3-1所示的算法描述。该方法虽然能满足读写互斥和写写互斥，但是不满足读读允许，只要有一个读者在读文件，其他的读者都被阻塞了。可见，单纯使用互斥信号量不能解决读者/

2、写者问题，还需要引入计数器对读者进行记数。2、读者优先如何纠正上述解法中存在的错误呢？其实，对于相继到达的一批读者，并不是每个读者都需要执行P（r_w_w）和V（r_w_w）。在这批读者中，只有最先到达的读者才需要执行P（r_w_w），与写者竞争对文件的访问权，假设执行P（r_w_w）成功则获得了文件的访问权，其他的读者可直接访问文件；同理，只有最后退出临界区的读者需要执行V（r_w_w）来归还文件访问权。为了记录正在读文件的一批读者的数量，需要设置一个整型变量readercount，每一个读者到达时都要将readercount加1，退出时都要将readercount减1。由于只要有一个读者在

3、读文件，便不允许写者写文件，所以，仅当readercount=0时，即尚无读者在读文件时，读者才需要执行P（r_w_w）操作。假设P（r_w_w）操作成功，读者便可去读文件，相应地，readercount+1。同理，仅当在执行了readercount减1操作后其值为0时，才需要执行V（r_w_w）操作，以便让写者写文件。又因为readercount是一个可被多个读者访问的临界资源，所以应该为它设置一个互斥信号量readercount_mutex.。每个读者在访问readercount之前执行P（readercount_mutex），之后执行V（readercount_mutex）。通过上述分析

4、得到图3-2所示的算法描述，其中的数字表示语句对应的行号。图3-2 读者优先算法01 semaphore r_w_w=1;02 semaphore readercount_mutex=1;03 int readercount=0; 04 reader（）05 P（readercount_mutex）;06 if（readercount=0） P（r_w_w）;07 readercount+;08 V（readercount_mutex）;09 读文件;10 P（readercount_mutex）;11 readercount-;12 if（readercount=0） V（r_w_w）;13

5、 V（readercount_mutex）;14 1516 writer（）17 P（r_w_w）;18 写文件;19 V（r_w_w）;20 3、写者优先通过增加信号量并修改上述程序可以得到写者优先算法。为了实现写者优先算法，需要将写者和读者分开排队，并且第一个读者和其它读者也要分开排队。这样就需要三个队列，一个是写者排队的地方，另一个是第一个读者排队的地方，第三个是其它读者排队的地方。相应地需要设置三个信号量，r_w_w、first_reader_wait和reader_wait。当一个写者声明想写文件时，可以让新的读者中的第一个到first_reader_wait上排队等待；当有读者阻塞

6、在first_reader_wait上时，让其它读者阻塞在reader_wait上；当有一个写者在写文件时，其它写者到r_w_w上排队。只要有活跃的写者或者写者队列不为空，则阻塞新到达的读者。为了记录已经发出声明的写者数量，需要设置一个整数writercount，以表示声明要写文件的写者数目。由于只要有一个写者到达，就不允许读者去读，因此仅当writercount=0，表示无写者声明写时，写者才需要执行P（first_reader_wait）操作，假设操作成功，写者便可以执行P（r_w_w）去竞争写文件权利。其它写者不需要再向读者声明，可以直接执行P（r_w_w）去竞争写文件权利。同理仅当写者

7、在执行writercount减1操作后其值为0时，才需要执行V（first_reader_wait）操作，以便唤醒第一个被阻塞的读者去读文件。又因为writercount是一个可被多个写者访问的临界资源，所以，应该为它设置一个互斥信号量writer_mutex。4、无优先除了在读者优先时需要的信号量r_w_w和readercount_mutex之外，还需要设置一个信号量wait供读者和写者排队。读者和写者都排在wait队列上。假设有读者在读文件，则第一个写者阻塞在r_w_w上，其它的写者和读者阻塞在wait上；假设有一个写者在写文件，则其它写者和读者都阻塞在wait上。无优先的算法描述如图3-

8、3所示。图3-3 无优先算法02 semaphore wait=1;03 semaphore readercount_mutex=1;04 int readercount=0;05 reader（）06 P（wait）;07 P（readercount_mutex）;08 if（readercount=0） P（r_w_w）;09 readercount+;10 V（readercount_mutex）;11 V（wait）;12 读文件;13 P（readercount_mutex）;14 readercount-;15 if（readercount=0） V（r_w_w）;16 V（rea

9、dercount_mutex）;17 18 writer（）19 P（wait）;20 P（r_w_w）;21 写文件;22 V（r_w_w）;23 V（wait）;24 3.3.2 程序功能及界面设计该程序采用简单的控制台应用程序界面，在主界面上显示程序的功能。该程序的功能如下：1.演示读者优先算法；2.演示写者优先算法；3.演示无优先算法；4.退出。3.3.3 函数设计实现读者/写者问题的源程序名称是reader_and_writer.cpp。该程序共包括10个函数。这些函数可以分成4组。各组包含的函数及其功能如图3-4。组别包括函数函数功能一main（）显示主菜单，接收用户的选择并执行相

10、应的功能。二RF_reader_thread（）RF_writer_thread（）reader_first（）读者优先算法的读者线程函数读者优先算法的写者线程函数读者优先算法的初始化函数：创建10个线程并等待它们结束三WF_reader_thread（）WF_writer_thread（）writer_first（）写者优先算法的读者线程函数写者优先算法的写者线程函数写者优先算法的初始化函数：四FIFO_reader_thread（）FIFO_writer_thread（）first_come_first_serverd（）无优先算法的读者线程函数无者优先算法的写者线程函数无者优先算法的初始

11、化函数：图3-4 函数功能简述程序开始部分定义了宏MAX_THREAD，表示程序中创建的线程数。还定义了测试数据的结构体TEST_INFO，该结构体包含三个数据项：线程名称；提出请求的时刻；操作持续时间。接着定义了全局变量，这些全局变量的作用如下：数组test_data保存了10个线程的测试数据；整数read_count记录一段时间内同时对文件进行读操作的线程数；整数write_count记录一段时间内提出写操作请求的线程数，该整数只在写者优先算法中使用；CS_DATA是临界区变量，用来保护文件，实现对文件的读写互斥和写写互斥相当于算法描述中的r_w_w；互斥体h_mutex_read_cou

12、nt用来保护整数read_count，以保证多个读者对read_count的互斥访问；互斥体h_mutex_write_count用来保护整数write_count，以保证多个写者对write_count的互斥访问，该互斥体只在写者优先算法中使用；互斥体h_mutex_first_reader_wait和h_mutex_reader_wait只在写者优先算法中使用，当有写者在写文件时，提出读请求的第一个读者阻塞在h_mutex_first_reader_wait上，其余的读者阻塞在h_mutex_reader_wait上；互斥体h_mutex_wait只在无优先算法中使用，当文件被使用时，后继

13、的读请求和写请求依次阻塞在h_mutex_wait上。3.3.4参考源程序3.3.4.1 Linux下的参考源程序编译命令gcc reader_and_writer .cpp o reader_and_writer.o lcurses lpthread程序清单#include pthread.hcurses.hstdlib.hstring.h#define MAX_THREAD 10 typedef struct char thread_name3; unsigned int require_moment; unsigned int persist_time;TEST_INFO;TEST_IN

14、FO test_dataMAX_THREAD= r1,0,15,r2,1, 15,w1,3,3,r3,4, 2,w2,5,6,w3,6,10,r4,7,8,r5,9,2,w4,10,18,w5,12,2;int read_count=0;int write_count=0;pthread_mutex_t CS_DATA;pthread_mutex_t h_mutex_read_count;pthread_mutex_t h_mutex_write_count;pthread_mutex_t h_mutex_reader_wait;pthread_mutex_t h_mutex_first_re

15、ader_wait;pthread_mutex_t h_mutex_wait;void* RF_reader_thread（void *data） strcpy（thread_name,（TEST_INFO *）data）-thread_name）; sleep（TEST_INFO *）data）-require_moment）; pthread_mutex_lock（&h_mutex_read_count）; read_count+; if（read_count=1） pthread_mutex_lock（&CS_DATA）; pthread_mutex_unlock（& printw（%s

16、 ,thread_name）; refresh（）;persist_time）; read_count-; if（read_count=0） pthread_mutex_unlock（& return 0;void* RF_writer_thread（void *data）,（TEST_INFO *）data）-void reader_first（） int i=0; pthread_t h_threadMAX_THREAD;reader first require sequence:）; for（i=0;iMAX_THREAD;i+） printw（,test_datai.thread_na

17、me）; ;nreader first operation sequence: pthread_mutex_init（&CS_DATA,NULL）; if（test_datai.thread_name0=r） pthread_create（&h_threadi,NULL,RF_reader_thread,&test_datai）; elseh_threadi,NULL,RF_writer_thread,& pthread_join（h_threadi,NULL）;void* FIFO_reader_thread（void *data）h_mutex_wait）;void* FIFO_write

18、r_thread（void *data）void first_come_first_served（）FCFS require sequence:FCFS:operation sequence:h_threadi,NULL,FIFO_reader_thread,&h_threadi,NULL,FIFO_writer_thread,&void* WF_reader_thread（void *data）h_mutex_reader_wait）;h_mutex_first_reader_wait）;void* WF_writer_thread（void *data）h_mutex_write_count）; if（write_count=0） write_count+; write_count-; pthread