线程安全

多线程的存在导致在不同线程执行任务存在了数据、操作的不安全性,称之为非原子性。为了解决开发遇到的线程不安全的现象,就要用到线程锁。分别有 @synchronized、NSLock、dispatch_semaphore、NSCondition、pthread_mutex、OSSpinLock,不同的锁有不同的使用场景和性能上的区别。

@synchronized

@synchronized(objc) 为开发中常用的锁,他以一个 objc 为锁的标示对象,在需要互斥的代码之间,这个 objc 必须为同一对象,不然,将达不到互斥的效果。

dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        @synchronized(self){
            NSLog(@"操作1开始");
            sleep(3);
            NSLog(@"操作1结束");
        }
    });
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        sleep(1);
        @synchronized(self){
            NSLog(@"操作2");
        }
    });

此段代码执行的结果为:

2018-08-15 15:14:48.387631+0800 Looks[4097:719747] 操作1开始
2018-08-15 15:14:51.391021+0800 Looks[4097:719747] 操作1结束
2018-08-15 15:14:51.391444+0800 Looks[4097:719750] 操作2

特点:简单易用,但性能最差。

dispatch_semaphore

GCD API 里面的信号量,也可以作为锁来使用,使用时搭配相关 API 使用。

dispatch_semaphore_t dispatch_semaphore_create(long value);

信号量的创建,value 为一个 long 类型的数,这里需要注意 value 应为非 0 的数,不然将起不到锁的效果。

long dispatch_semaphore_signal(dispatch_semaphore_t dsema);

这个函数会对 参数 dsema 的值加 1。

long dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout);

这个函数会对参数 dsema 的值减 1,该函数执行时当 dsema 的值大于0,不阻塞当前线程,执行后面操作,将 dsema 减1,当 dsema 等于 0 时,那么函数将会阻塞线程 timeout 时间,timeout 为 dispatch_time_t 类型,如果等待的期间 dsema 值被 dispatch_semaphore_signal 函数加了1,且获取到了信号量,那么线程将会执行大于0时的一样的操作,如果在等待且信号量没变且到了所设置的等待时间,那么将不再等待,执行后面操作。可设置 timeout 为 DISPATCH_TIME_FOREVER,这样将一直阻塞线程直到信号量改变。

dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, 3 * NSEC_PER_SEC));
        NSLog(@"操作1开始");
        sleep(3);
        NSLog(@"操作1结束");
        dispatch_semaphore_signal(semaphore);
        
    });
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        sleep(1);
        dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, 3 * NSEC_PER_SEC));
        NSLog(@"操作2");
        dispatch_semaphore_signal(semaphore);
        
    });
    

以上代码 timeout > 2s 时,结果为:

2018-08-15 15:31:22.385087+0800 Looks[4411:738446] 操作1开始
2018-08-15 15:31:25.385388+0800 Looks[4411:738446] 操作1结束
2018-08-15 15:31:25.385653+0800 Looks[4411:738445] 操作2

如果 timeout < 2s 时,结果为:

2018-08-15 15:51:39.012859+0800 Looks[4632:759034] 操作1开始
2018-08-15 15:51:41.019446+0800 Looks[4632:759031] 操作2
2018-08-15 15:51:42.015130+0800 Looks[4632:759034] 操作1结束

特点:在不出现等待的情况下,性能最高。

NSLock

NSLock 也是我们经常用的一种锁。

- (void)lock;
- (void)unlock;

遵循了 NSLocking 协议,搭配的分别为锁和解锁。

- (BOOL)tryLock;
- (BOOL)lockBeforeDate:(NSDate *)limit;

tryLock:试图加锁并立即返回一个布尔值,该值指示尝试是否成功。如果返回 YES,加锁成功,反之失败。
lockBeforeDate:表示在指定时间之前加锁,如果到指定时间加锁成功,则返回 YES,加锁成功,反之失败。

    NSLock *lock = [NSLock new];
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        if ([lock tryLock]) {
            NSLog(@"操作1开始");
            sleep(3);
            NSLog(@"操作1结束");
            [lock unlock];
        }
    });
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        sleep(1);
        if ([lock tryLock]) {
            NSLog(@"操作2");
            [lock unlock];
        }else{
            NSLog(@"tryLock 失败");
        }
        
        if ([lock lockBeforeDate:[NSDate dateWithTimeIntervalSinceNow:3]]) {
            NSLog(@"lockBeforeData 获取到锁");
            [lock unlock];
        }else{
            NSLog(@"lockBeforeData 超时,未获取到锁");
        }
        
    });
    

以上代码执行结果为:

2018-08-15 16:44:03.240428+0800 Looks[5079:796065] 操作1开始
2018-08-15 16:44:04.241003+0800 Looks[5079:796066] tryLock 失败
2018-08-15 16:44:06.241563+0800 Looks[5079:796065] 操作1结束
2018-08-15 16:44:06.242126+0800 Looks[5079:796066] lockBeforeData 获取到锁

特点:方便简单易用。

NSRecursiveLock (递归锁)

NSRecursiveLock 是常用在处理递归循环操作上的锁,所以叫递归锁。他可以处理同一个线程多次加锁,解锁而不会引起死锁。同样遵循 NSLocking 协议,API 和用法都和 NSLock 相同,不同的只有使用场景。

    NSRecursiveLock *recursiveLock = [NSRecursiveLock new];
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        static void (^ RecursiveLock)(int);
        RecursiveLock = ^ (int value){
            
            [recursiveLock lock];
            if (value > 0) {
                NSLog(@"value is %d",value);
                sleep(1);
                value -= 1;
                RecursiveLock(value);
            }
            [recursiveLock unlock];
        };
        
        RecursiveLock(4);
    });

以上代码执行 lock 和 unlock 一一对应,在统一线程中递归加锁解锁,这就是 NSRecursiveLock 的使用场景,执行结果为:

2018-08-16 13:57:30.195998+0800 Looks[3695:302951] value is 4
2018-08-16 13:57:31.197983+0800 Looks[3695:302951] value is 3
2018-08-16 13:57:32.201241+0800 Looks[3695:302951] value is 2
2018-08-16 13:57:33.205673+0800 Looks[3695:302951] value is 1

特点:对同一线程多次加锁、解锁。递归循环条件下适用。

NSConditionLock (条件锁)

这种锁不仅具备了 lock 和 unlock 功能,还有在 lock 和 unlock 的条件操作功能,这也丰富了我们使用的选择和场景。

- (void)lockWhenCondition:(NSInteger)condition;
- (BOOL)tryLock;
- (BOOL)tryLockWhenCondition:(NSInteger)condition;
- (void)unlockWithCondition:(NSInteger)condition;
- (BOOL)lockBeforeDate:(NSDate *)limit;
- (BOOL)lockWhenCondition:(NSInteger)condition beforeDate:(NSDate *)limit;

和之前几个锁的 API 大同小异,唯一不同的就是多了一个参数 condition,这个参数就是我们要说的 lock 和 unlock 的条件, 当 lock 时 condition 的参数和初始化参数一致时,将不阻塞线程,进行加锁继续后续操作,反之,将阻塞线程。而 unlock 时,condition 则是将更改为实参的值,解锁完成操作或者为下一次个 lock 的 condition 做准备。

    NSConditionLock *conditionLock = [NSConditionLock new];
    NSMutableArray *array = [NSMutableArray new];
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        while (YES) {
            [conditionLock lockWhenCondition:0];
            [array addObject:[NSString stringWithFormat:@"%d", arc4random() % 10]];
            NSLog(@"arry count is %lu",(unsigned long)array.count);
            [conditionLock unlockWithCondition:1];
            sleep(1);
        }
    });
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        while (YES) {
            NSLog(@"condition 不相同, wait....");
            [conditionLock lockWhenCondition:1];
            [array removeObjectAtIndex:0];
            NSLog(@"arry remove object at index for zero");
            [conditionLock unlockWithCondition:0];
            sleep(1);
        }
    });

以上代码执行结果为:

2018-08-16 14:19:09.390035+0800 Looks[4082:324058] arry count is 1
2018-08-16 14:19:09.390044+0800 Looks[4082:324059] condition 不相同, wait....
2018-08-16 14:19:09.390216+0800 Looks[4082:324059] arry remove object at index for zero
2018-08-16 14:19:10.391602+0800 Looks[4082:324059] condition 不相同, wait....
2018-08-16 14:19:10.391551+0800 Looks[4082:324058] arry count is 1
2018-08-16 14:19:10.391967+0800 Looks[4082:324059] arry remove object at index for zero

特点:当有加锁解锁条件时适用。

NSCondition

也是经常用且简单的一种锁,同样遵循 NSLocking 协议,实现了 lock 和 unlock 方法。

- (void)wait;
- (BOOL)waitUntilDate:(NSDate *)limit;
- (void)signal;
- (void)broadcast;

wait:阻塞当前线程,让线程处于等待状态,直到有线程信号,在调用此方法时,锁必须是 lock 状态。
waitUntilDate:阻塞当前线程,让线程处于等待状态直到条件发出信号或达到指定的时间限制。在调用此方法时,锁必须是 lock 状态。
signal:信号条件,唤醒一个等待线程。可以使用此方法唤醒正在等待条件的一个线程。可以多次调用此方法以唤醒多个线程。如果没有线程在等待条件,这个方法什么也不做。
broadcast:信号条件,唤醒所有等待它的线程。如果没有线程在等待条件,这个方法什么也不做。

    NSCondition *codition = [NSCondition new];
    NSMutableArray *array = [NSMutableArray new];
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        while (YES) {
            [codition lock];
            if (array.count == 0 ) {
                NSLog(@"wait ....");
                [codition wait];
            }
            [array removeObjectAtIndex:0];
            NSLog(@"array remove object index for zero");
            [codition unlock];
        }
    });
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        while (YES) {
            [codition lock];
            [array addObject:[NSString stringWithFormat:@"%d",arc4random() % 10]];
            NSLog(@"array count is %lu",(unsigned long)array.count);
            [codition signal];
            [codition unlock];
            sleep(1);
        }
    });

以上代码执行的结果为:

2018-08-16 15:26:09.625351+0800 Looks[5145:383490] wait ....
2018-08-16 15:26:09.625543+0800 Looks[5145:383492] array count is 1
2018-08-16 15:26:09.625729+0800 Looks[5145:383490] array remove object index for zero
2018-08-16 15:26:09.626445+0800 Looks[5145:383490] wait ....
2018-08-16 15:26:10.629679+0800 Looks[5145:383492] array count is 1
2018-08-16 15:26:10.630167+0800 Looks[5145:383490] array remove object index for zero

特点:类似于 GCD 的信号量,但更直观面向对象,有更强的 wait 和 signal 操作性。

pthread_mutex

c 语言定义下的线程锁,其他好多锁都是对他的封装,也是性能相对最高的一个。

int pthread_mutex_init(pthread_mutex_t * __restrict, const pthread_mutexattr_t * _Nullable __restrict);
int pthread_mutex_lock(pthread_mutex_t *);
int pthread_mutex_trylock(pthread_mutex_t *);
int pthread_mutex_unlock(pthread_mutex_t *);
int pthread_mutexattr_settype(pthread_mutexattr_t *, int);
int pthread_mutexattr_destroy(pthread_mutexattr_t *) __DARWIN_ALIAS(pthread_mutexattr_destroy);

c 语言下提供了很多有关的操作 API,这里不多说,只列了常用这几个。

pthread_mutex_init:动态创建一个锁,第二个参数,NULL 为默认类型,一共用四种类型:

PTHREAD_MUTEX_NORMAL :缺省类型,也就是普通锁。当一个线程加锁以后,其余请求锁的线程将形成一个等待队列,并在解锁后先进先出原则获得锁。
PTHREAD_MUTEX_ERRORCHECK :检错锁,如果同一个线程请求同一个锁,则返回 EDEADLK,否则与普通锁类型动作相同。这样就保证当不允许多次加锁时不会出现嵌套情况下的死锁。
PTHREAD_MUTEX_RECURSIVE :递归锁,允许同一个线程对同一个锁成功获得多次,并通过多次unlock 解锁。
PTHREAD_MUTEX_DEFAULT :适应锁,动作最简单的锁类型,仅等待解锁后重新竞争,没有等待队列。

还有一种静态创建的方式:pthread_mutex_tmutex = PTHREAD_MUTEX_INITIALIZER static 或者全局变量。

pthread_mutexattr_settype:可以用来设置锁的类型,比如递归锁。

    static pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
//    __block pthread_mutex_t lock;
//    pthread_mutex_init(&lock, PTHREAD_MUTEX_NORMAL);
    
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        pthread_mutex_lock(&lock);
        NSLog(@"操作1开始");
        sleep(3);
        NSLog(@"操作1结束");
        pthread_mutex_unlock(&lock);
    });
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        sleep(1);
        pthread_mutex_lock(&lock);
        NSLog(@"操作2");
        pthread_mutex_unlock(&lock);
    });
以上代码执行结果为:

2018-08-16 16:31:19.333924+0800 Looks[6291:445780] 操作1开始
2018-08-16 16:31:22.339330+0800 Looks[6291:445780] 操作1结束
2018-08-16 16:31:22.339820+0800 Looks[6291:445781] 操作2

特点:基于 c 语言的 API,性能相对是最好的,可操作性更强,但 API 较多。

OSSpinLock

OSSpinLock 自旋锁,在线程阻塞等待的时候会一直轮询状态,这样在等待的时候会消耗大量资源。不过有 bug,已被弃用,弃用原因为:如果一个低优先级的线程获得锁并访问共享资源,这时一个高优先级的线程也尝试获得这个锁,它会处于 spinlock 的忙等状态从而占用大量 CPU。此时低优先级线程无法与高优先级线程争夺 CPU 时间,从而导致任务迟迟完不成、无法释放lock。所以 apple 的停用了 OSSpinLock, 所以在这不在做过多的介绍。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,948评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,371评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,490评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,521评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,627评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,842评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,997评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,741评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,203评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,534评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,673评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,339评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,955评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,770评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,000评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,394评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,562评论 2 349

推荐阅读更多精彩内容