iOS中读写锁的简单实现方法实例

ios 读写锁 2022-06-04 15:06:04 705人浏览八月长安

摘要

目录废话开篇思考一、对于锁的类型的理解思考二、读写锁的实现逻辑思考三、简单封装读写锁，满足读写逻辑总结废话开篇 iOS 下的多线程的技术的应用衍生出了锁的机制，试想，如果 ioS 下

废话开篇

iOS 下的多线程的技术的应用衍生出了锁的机制，试想，如果 ioS 下没有多线程的概念，所有的代码都会在同步环境下执行，那么，也就不会产生争夺资源情况的发生，当然，也就没有办法利用多核的优势。所以，多线程的应用是广布的，而锁的应用是局部的，所以，二者应相辅相成，来达到提高运行效率的同时提高程序运行的稳定性。

思考一、对于锁的类型的理解

基本的三种锁的类型：互斥锁、自旋锁、读写锁。

其中，互斥锁多线程在访问加锁中的临界区前，会进入休眠，一直等待解锁后系统调度；自旋锁多线程在访问加锁中的临界区前，不进入休眠，会一直忙等。读写锁是一种思想，本质就是利用互斥锁来实现特定的应用场景：多读并行、读与写互斥，写与写互斥；对于其他的类型的锁，比如：信号量、条件锁、递归锁，可以理解为是由以上基本类型的锁实现的上层封装。

思考二、读写锁的实现逻辑

如果有这样一块公共资源，它的写入是比较耗时，那么，在这段时间内要避免程序再次的进行写入操作和读取操作，这样可以避免产生争夺资源的问题，当然，读取的过程可以并行。

先上一段代码，这里模拟一个比较耗时的写入过程，在模拟一个快速读取的过程。


//读写锁
- (void)readAndWriteLock
{
    //写
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
            NSLog(@"我开始写");
            for (int i = 0; i < 10000; i++) {
            }
            NSLog(@"我写完了");

    });

    //读
    for (int i = 0; i < 10; i++) {
        dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
            NSLog(@"我开始读%d",i);
            for (int j = 0; j < i; j++) {
            }
            NSLog(@"我读完了%d",i);
        });
    }
}

在写入的异步内执行了循环 10000 次的操作来模拟耗时任务；后面开辟了多线程进行读取，在读取的异步里，实现简单的不同数量的循环来模拟耗时任务，这里的耗时次数远小于写入。

打印如下

通过输出可以清晰的看到，写入过程中还有很多读取的操作在同时进行。致于是先开始读取还是开始写入，这里其实并不用去关心，本身它们也是由系统决定的，但是，这里需要控制一下代码，来实现读写互斥，即在写的过程中，禁止读取操作的介入。同时，也需要实现写写互斥。对于，多读，其实这里并不需要过多干涉，因为，本身就允许多读的逻辑。

思考三、简单封装读写锁，满足读写逻辑

利用互斥锁封装读取加、解锁；写入加、解锁


//初始化读取锁
static pthread_mutex_t r_plock =  PTHREAD_MUTEX_INITIALIZER;
//初始化写入锁
static pthread_mutex_t w_plock =  PTHREAD_MUTEX_INITIALIZER;
//记录当前读取次数，因为只要其值不为0，那么，就说明程序在读取操作，这里停止写入操作
static int current_read_times = 0;

进行读取加锁


//读加锁
- (void)readLock
{
    pthread_mutex_lock(&r_plock);
    current_read_times ++;
    if (current_read_times == 1) {
        pthread_mutex_lock(&w_plock);
    }
    pthread_mutex_unlock(&r_plock);
}

这里首先进行读取锁加锁，这里加锁的目的并不是锁定读取过程，而是锁定了修改 current_read_times 的过程，当 current_read_times 变更后，如果为 1，那么，就对写入锁加锁，这个写入锁就是锁住写入过程的。这两个锁的应用部分是有区别的。

进行读取解锁


//读解锁
- (void)readUnLock
{
    pthread_mutex_lock(&r_plock);
    current_read_times --;
    if (current_read_times == 0) {
        pthread_mutex_unlock(&w_plock);
    }
    pthread_mutex_unlock(&r_plock);
}

这里首先进行读取锁加锁，目的还是对 current_read_times 修改的锁，可以总结一下，读写锁本质并不对多读进行限制，所以，这里的读取锁是锁住 current_read_times 修改过程，在加锁的情况下进行写入锁状态的变更，实现读与写的互斥。后面进行状态判断，如果 current_read_times 为 0，说明当前所以读取完成了，那么，对写入锁进行解锁，解锁后写入操作就可以正常进行。这里解锁的判断为 == 0 与加锁的判断 == 1 是一对，这样就满足了，一个加锁过程对应一个解锁条件。不会出现只有加锁后而没有解锁的情况。

进行写入加锁


//写加锁
- (void)writeLock
{
    pthread_mutex_lock(&w_plock);
}

这里仅仅是对写入操作进行加锁。

进行写入解锁


//写解锁
- (void)writeUnLock
{
    pthread_mutex_unlock(&w_plock);
}

这里仅仅是对写入操作进行解锁。

最后的代码


//读写锁
- (void)readAndWriteLock
{
    //写
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
            [self writeLock];
            NSLog(@"我开始写");
            for (int i = 0; i < 10000; i++) {

            }
            NSLog(@"我写完了");
            [self writeUnLock];
    });
    
    //读
    for (int i = 0; i < 10; i++) {
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
            [self readLock];
            NSLog(@"我开始读%d",i);
            for (int j = 0; j < i; j++) {

            }
            NSLog(@"我读完了%d",i);
            [self readUnLock];
        });
    }
}

打印如下