读者写者模式

在编写多线程的时候,有一种情况是比较常见的。那就是,有些公共数据修改的机会比较少。相较改写,它们读的机会反而多的多。

读者写者模式:三种关系,两类人,一个场所

三种关系:

读者与读者:无关系

写者与写者:互斥

读者与写者:同步与互斥

两类人:读者,写者

一个场所:同一临界资源(数据)

自旋锁:如果所等待条件不满足,不挂起,一直申请锁。适宜某个线程占用锁时间较短。

当不断有多个读者准备读时,如果有写者到来,此时应该当前读者读完后,提高写者优先级,下个进入临界区的是写者。---------写者优先,否则会造成写者饥饿

当不断有多个写者准备写时,如果有读者到来,此时应该当前写者写完后,提高读者优先级,下个进入临界区的是读者。---------读者优先,否则会造成读者饥饿

读写锁相关函数:

#include <pthread.h>

int pthread_rwlock_destroy(pthread_rwlock_t *rwlock);

int pthread_rwlock_init(pthread_rwlock_t *restrict rwlock,

const pthread_rwlockattr_t *restrict attr);

int pthread_rwlock_trywrlock(pthread_rwlock_t *rwlock);

int pthread_rwlock_wrlock(pthread_rwlock_t *rwlock);//写者优先

int pthread_rwlock_rdlock(pthread_rwlock_t *rwlock);//读者优先

int pthread_rwlock_tryrdlock(pthread_rwlock_t *rwlock);

#include<stdio.h>
#include<pthread.h>
int g_val=0;
pthread_rwlock_t rw_lock;
void* reader(void* arg)
{
    while(1)
    {
        pthread_rwlock_rdlock(&rw_lock);
        printf("g_val: %d\n",g_val);
        pthread_rwlock_unlock(&rw_lock);
    }
}
void* writer(void* arg)
{
    while(1)
    {
        sleep(1);//使写者隔一秒竞争一次锁资源
        pthread_rwlock_wrlock(&rw_lock);
        g_val++;
        pthread_rwlock_unlock(&rw_lock);
    }
}

int main()
{
    pthread_t tid1,tid2;
    pthread_rwlock_init(&rw_lock,NULL);
    pthread_create(&tid1,NULL,reader,NULL);
    pthread_create(&tid2,NULL,writer,NULL);
    pthread_rwlock_destroy(&rw_lock);
    pthread_join(tid1,NULL);
    pthread_join(tid2,NULL);
    return 0;
}
时间: 2024-12-20 11:46:54

读者写者模式的相关文章

读者写者模式举例

/*   * 读者写者问题   *    * */ class Buffer {     public String buffer[] = new String[10];//用于标识共享的缓冲区       public boolean flag = false;//用于标识缓冲区的状态       public int i=0;//表示向缓冲区写的位置    } class Writer implements Runnable //可能会有多个读   {     private Buffer 

用信号量和读写锁解决读者写者问题

读者写者问题是非常经典的同步问题,本文首先用信号量来解决这个问题,并结合代码分析什么是读者优先.什么是写者优先,然后给出读写锁的解决方案,并指出在Linux下读写锁的注意事项. 读者写者问题 读者写者问题描述的是这么一种情况:对象在多个线程(或者进程)之间共享,其中一些线程只会读数据,另外一些线程只会写数据.为了保证写入和读取的正确性,我们需要保证,只要有线程在写,那么其他线程不能读,否则可能读到写了一半的数据:另外,也不能有两个线程同时写,否则导致数据错乱.当然,多个线程是可以同时读数据. 读

Java实现生产者消费者问题与读者写者问题

摘要: Java实现生产者消费者问题与读者写者问题 1.生产者消费者问题 生产者消费者问题是研究多线程程序时绕不开的经典问题之一,它描述是有一块缓冲区作为仓库,生产者可以将产品放入仓库,消费者则可以从仓库中取走产品.解决生产者/消费者问题的方法可分为两类:(1)采用某种机制保护生产者和消费者之间的同步:(2)在生产者和消费者之间建立一个管道.第一种方式有较高的效率,并且易于实现,代码的可控制性较好,属于常用的模式.第二种管道缓冲区不易控制,被传输数据对象不易于封装等,实用性不强. 同步问题核心在

利用JAVA线程安全队列简单实现读者写者问题。

常见的操作系统教科书中,会使用互斥锁来实现读者线程和写者线程的同步问题,但是在JDK5推出线程安全队列之后,将该问题变得异常简单. java.util.concurrent.ConcurrentLinkedQueue 是线程安全的非阻塞队列,其实很容易想到,非阻塞队列当线程需要等待的时候,则不会阻塞等待,而是直接根据情况返回. java.util.concurrent.LinkedBlockingQueue 是线程安全的阻塞队列,该队列能够在很多情况下对线程进行阻塞,比如队列为空时调用take(

Linux多线程实践(6) --Posix读写锁解决读者写者问题

Posix读写锁 int pthread_rwlock_init(pthread_rwlock_t *restrict rwlock, const pthread_rwlockattr_t *restrict attr); int pthread_rwlock_destroy(pthread_rwlock_t *rwlock); int pthread_rwlock_rdlock(pthread_rwlock_t *rwlock); int pthread_rwlock_wrlock(pthre

秒杀多线程第十一篇 读者写者问题

与上一篇<秒杀多线程第十篇 生产者消费者问题>的生产者消费者问题一样,读者写者也是一个非常著名的同步问题.读者写者问题描述非常简单,有一个写者很多读者,多个读者可以同时读文件,但写者在写文件时不允许有读者在读文件,同样有读者在读文件时写者也不去能写文件. 上面是读者写者问题示意图,类似于生产者消费者问题的分析过程,首先来找找哪些是属于“等待”情况. 第一.写者要等到没有读者时才能去写文件. 第二.所有读者要等待写者完成写文件后才能去读文件. 找完“等待”情况后,再看看有没有要互斥访问的资源.由

js 要写严格模式

js 为了能在移动端通用,要写严格模式: 这里多了个逗号,在pc上浏览器可以通过,但是在手机端就不能.

多线程---读者写者问题

有几种思路 1.利用信号量来实现读者写者的互斥(读者和读者之间是并行的) public class ReaderAndWriter { private static AtomicInteger reader = new AtomicInteger(); private static AtomicInteger blocked = new AtomicInteger(); //用来对读者写者互斥 private static Semaphore ws = new Semaphore(1,true)

多线程面试题系列(14):读者写者问题继 读写锁SRWLock

在第十一篇文章中我们使用事件和一个记录读者个数的变量来解决读者写者问题.问题虽然得到了解决,但代码有点复杂.本篇将介绍一种新方法--读写锁SRWLock来解决这一问题.读写锁在对资源进行保护的同时,还能区分想要读取资源值的线程(读取者线程)和想要更新资源的线程(写入者线程).对于读取者线程,读写锁会允许他们并发的执行.当有写入者线程在占有资源时,读写锁会让其它写入者线程和读取者线程等待.因此用读写锁来解决读者写者问题会使代码非常清晰和简洁. 下面就来看看如何使用读写锁,要注意编译读写锁程序需要V