码迷,mamicode.com
首页 > 其他好文 > 详细

读者---写者问题

时间:2015-05-14 15:56:07      阅读:192      评论:0      收藏:0      [点我收藏+]

标签:

                                           经典进程同步与互斥问题
读者---写者问题
1.问题描述
一个数据对象若被多个并发进程所共享,且其中一些进程只要求读该数据对象的内容,而另一些
进程则要求写操作,对此,把只想读的进程称为“读者”,而把要求写的进程称为“写者”。在
读者--写着问题中,任何时刻要求“写者”最多只允许有一个,而读者则允许有多个。因为多个
读者的行为互不干扰,他们只是读数据,而不改变数据对象的内容,而写者则不同,他们要改变数据对象的内容,如果他们同时操作,则数据对象的内容将会改变的不可知。所以对共享资源的读写操作的限制条件是:
1>允许任意多的读进程同时读;
2>一次只允许一个写进程写操作;
3>如果有一个写进程正在进行写操作,禁止任何读进程进行读操作。
2.用信号量解决读者--写着问题
为了解决“写着与写着”和“写着与第一个读者”的互斥问题即可,为此引入互斥信号量Wmutex。
为了记录谁是第一个读者,可以用一个全局整型变量Rcount做一个计数器。而在解决问题的过程中,由于使用了全局变量Rcount,该变量又是一个临界资源,对于他的访问仍需互斥进行,所以需要
一个互斥信号量Rmutex。
3.思考问题
对于读者---写者问题,有以下三种策略。
1>读者优先。即当读者进行读时,后续的写者必须等待,直到所有的读者均离开后,写着才可进入。
2>写者优先。即当一个写者到来时,只有那些已经获得授权允许读的进程才允许完成他们的操作,
写者之后到来的读者将被推迟,直到写者完成。在该策略中,如果有一个不可中断的连续的写者,
读者进程会被无限期的推迟。
3>公平策略。以上两种策略,读者或写进程中一个对一个有绝对的优先权,Hoare提出了一种更公平
的策略,由如下规则定义。
规则1:在一个读序列中,如果有写者在等待,那么就不允许有新的读者开始执行。
规则2:在一个写操作结束时,所有等待的读者应该比下一个写者有更高的优先权。
对于公平策略,又如何解决呢?

 

技术分享
#include <pthread.h>
#include <semaphore.h>
#include <sys/types.h>
#include <stdio.h>
#include <unistd.h>
#include<stdlib.h>
int Rcount=0,num=0;   //被保护的全局变量
sem_t Wmutex,Rmutex,mutex;
void* read1(void *arg)
{
 sem_wait(&mutex);
 sem_wait(&Rmutex);//读者到来
 if(Rcount==0)
 {
   printf("第一个读者到来\n");
   sem_wait(&Wmutex);
 }
 Rcount=Rcount+1;//读者数目
 sem_post(&Rmutex);
 sem_post(&mutex);
 printf("线程%lu正在进行读数据%d\n",pthread_self(),num);
 sleep(1);
 sem_wait(&Rmutex);//读者阅读结束
 Rcount=Rcount-1;
 if(Rcount==0)//所有的读者阅读结束
 {
     sem_post(&Wmutex);
     printf("读者全部退出\n");
 }
 sem_post(&Rmutex);
}
 
void* write1(void *arg)
{
 sem_wait(&mutex);
 sem_wait(&Wmutex);
 num=num+1;
 printf("线程%lu正在进行写数据%d\n",pthread_self(),num);
 sem_post(&Wmutex);
 sem_post(&mutex);
}
int main(int argc,char *argv[])
{     int i=0;
      int j=3;
      pthread_t tid[5];
      sem_init(&Wmutex,0,1);  
      sem_init(&Rmutex,0,1);  
      sem_init(&mutex,0,1);  
      while(i<=2)
        {
           if((pthread_create(&tid[i],NULL,read1,NULL))!=0)
                {
                        printf("can‘t create pthread.\n");
                       exit(0);
                }
                i++;
        }
        while(j<=4)
        {
           if((pthread_create(&tid[j],NULL,write1,NULL))!=0)
                {
                        printf("can‘t create pthread.\n");
                       exit(0);
                }
                j++;
        }
      for(i=0;i<5;i++)
        pthread_join(tid[i],NULL); 
      sem_destroy(&Wmutex); 
      sem_destroy(&Rmutex); 
      printf("程序运行结束\n");
      return 0;
}
写者优先

 

技术分享
#include <pthread.h>
#include <semaphore.h>
#include <sys/types.h>
#include <stdio.h>
#include <unistd.h>
#include<stdlib.h>
int Rcount=0,num=0;   //被保护的全局变量
sem_t Wmutex,Rmutex;
void* read1(void *arg)
{
 sem_wait(&Rmutex);//读者到来
 if(Rcount==0)
 {
   printf("第一个读者到来\n");
   sem_wait(&Wmutex);
 }
 Rcount=Rcount+1;//读者数目
 sem_post(&Rmutex);
 printf("线程%lu正在进行读数据%d\n",pthread_self(),num);
 sleep(1);
 sem_wait(&Rmutex);//读者阅读结束
 Rcount=Rcount-1;
 if(Rcount==0)//所有的读者阅读结束
 {
     sem_post(&Wmutex);
     printf("读者全部退出\n");
 }
 sem_post(&Rmutex);

}
 
void* write1(void *arg)
{
 sem_wait(&Wmutex);
 num=num+1;
 printf("线程%lu正在进行写数据%d\n",pthread_self(),num);
 sem_post(&Wmutex);
}
int main(int argc,char *argv[])
{     int i=0;
      int j=3;
      pthread_t tid[5];
      sem_init(&Wmutex,0,1);  // 空闲的
      sem_init(&Rmutex,0,1);  // 忙的
      while(i<=2)
        {
           if((pthread_create(&tid[i],NULL,read1,NULL))!=0)
                {
                        printf("can‘t create pthread.\n");
                       exit(0);
                }
                i++;
        }
        while(j<=4)
        {
           if((pthread_create(&tid[j],NULL,write1,NULL))!=0)
                {
                        printf("can‘t create pthread.\n");
                       exit(0);
                }
                j++;
        }
      for(i=0;i<5;i++)
        pthread_join(tid[i],NULL); 
      sem_destroy(&Wmutex); 
      sem_destroy(&Rmutex); 
      printf("程序运行结束\n");
      return 0;
}
读者优先

 

读者---写者问题

标签:

原文地址:http://www.cnblogs.com/leijiangtao/p/4503121.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!