GCD—Semaphore 很简单

上一篇 [iOS多线程-GCD之dispatch_barrier_async]
(http://www.jianshu.com/p/d63c3100dd63)

一、前言

Semaphore,一般称作信号量,相信学习过GCD的童靴对它一定不陌生,它的类型全称是 dispatch_queue_t。本篇我们先介绍一下semaphore.h里面的接口,然后再引用AFNetworking中的代码片段分析它的应用场景。

二、semaphore.h很简单

先看一个非常简单的加锁代码,semaphore一般的用法都和这个例子类似:

- (void)testDispatchSemaphore
{
    //获取一个全局队列
    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    //可变数组
    NSMutableArray *mutableArray = [NSMutableArray array];
    
    //创建一个计数为1的信号量
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
    
    for (int i = 0; i < 100000; ++i) {
        dispatch_async(queue, ^{
            //等待semaphore计数大于等于1,减1而不等待
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            
            [mutableArray addObject:[NSNumber numberWithInt:i]];
            
            //执行完后将semaphore计数加1
            dispatch_semaphore_signal(semaphore);
        });
    }
}

你可以尝试把semaphore相关的代码注释掉,运行一遍(bu beng kui lai zhao wo)。好了,代码我们稍后再分析。回到semephore.h,如何找到这个头文件呢?随便打开一个工程,在某个方法里面写上dispatch_queue_ t,command+左键进入到文件里面,它被包括在GCD的库文件dispatch里面,其中只有三个方法:

//创建一个计数为value的信号量,value为同时可访问的线程数
dispatch_semaphore_t dispatch_semaphore_create(long value);

//如果信号量大于零,则不会阻塞当前线程,并且信号量减1;如果等于零,阻塞当前线程直到信号量大于零
long dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout);

//将信号量计数加1,这样会唤醒一个被阻塞的线程
long dispatch_semaphore_signal(dispatch_semaphore_t dsema);

好,我们再来看示例代码。代码尝试在多线程的环境下给一个可变数组添加对象,由于NSMutableArray并不是线程安全的,因此我们得为添加对象的代码加锁。没错,这就是semaphore的第一个用法了

信号量并不是一个整形或浮点型,它本质是一个dispatch_object类型,只能通过signalwait函数来加1和减1。我推测(xia bai),它是一个Objective-C类型的结构体,其中包含一个计数的变量,所以更专业的说法是“信号量计数”加1或减1,这里我就直接说成信号量加1或减1了。

一、问题

运行下面这段代码:

- (void)testDispatchSemaphore
{
    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    NSMutableArray *mutableArray = [NSMutableArray array];
    
    for (int i = 0; i < 100000; ++i) {
        dispatch_async(queue, ^{
            [mutableArray addObject:[NSNumber numberWithInt:i]];
        });
    }
}

结果异常

GCDLearn(907,0x7000002a0000) malloc: *** error for object 0x7faf63823c00: double free
*** set a breakpoint in malloc_error_break to debug

毫无疑问,会产生异常,原因是:在多个线程中对mutableArray添加对象时,访问了同一块内存,产生了资源竞争。这时候大家都会想到加锁了,Dispatch Semaphore就可以完成这一功能。

线程锁的实现方式有多种,自旋锁OSSpinLock已经不再安全,Dispatch Semaphore是目前性能最好的加锁方式,参考:http://www.jianshu.com/p/8b8a01dd6356

二、解决

Dispatch Semaphore加锁由以下三行代码实现

//创建信号量
dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
//信号量计数减1
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
//信号量计数加1
dispatch_semaphore_signal(semaphore);

dispatch_semaphore_create(1)
创建一个计数为1的信号量semaphore;

dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER)
当semaphore为0时,会一直等待semaphore大于或等于1;大于等于1时,将semaphore计数减1而不用等待;

dispatch_semaphore_signal(semaphore)
将semaphore计数加1。

用Dispatch Semaphore解决上面的问题:

- (void)testDispatchSemaphore
{
    //获取一个全局队列
    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    //可变数组
    NSMutableArray *mutableArray = [NSMutableArray array];
    
    //创建一个计数为1的信号量
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
    
    for (int i = 0; i < 100000; ++i) {
        dispatch_async(queue, ^{
            //等待semaphore计数大于等于1,减1而不等待
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            
            [mutableArray addObject:[NSNumber numberWithInt:i]];
            
            //执行完后将semaphore计数加1
            dispatch_semaphore_signal(semaphore);
        });
    }
}

执行代码,不会再崩溃了,ok!
分析:semaphore初始化计数为1能够保证同一时间只有一个线程能够执行这段代码,达到了加锁的目的。

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

推荐阅读更多精彩内容

  • 锁是一种同步机制,用于多线程环境中对资源访问的限制iOS中常见锁的性能对比图(摘自:ibireme): iOS锁的...
    LiLS阅读 1,503评论 0 6
  • demo下载 建议一边看文章,一边看代码。 声明:关于性能的分析是基于我的测试代码来的,我也看到和网上很多测试结果...
    炸街程序猿阅读 777评论 0 2
  • 线程安全是怎么产生的 常见比如线程内操作了一个线程外的非线程安全变量,这个时候一定要考虑线程安全和同步。 - (v...
    幽城88阅读 644评论 0 0
  • 多线程概念 线程线程指的是:1个CPU执行的CPU命令列为一条无分叉路径 多线程这种无分叉路径不止一条,存在多条即...
    我系哆啦阅读 571评论 0 5
  • 我向来就不是一个果断决绝的人,面对选择面对判断,我都会犹豫踌躇一段时间。小到吃饭还是吃面,大到继续读书还是...
    Amanda_DQQ阅读 198评论 1 1