3.2 GCD 的 API

3.2.1 Dispatch Queue

开发者要做的只是定义想执行的任务并追加到适当的 Dispatch Queue 中。
Dispatch Queue 按照追加的顺序(先进先出 FIFO,First-In-First-Out)执行处理。

Dispatch Queue 可分为以下2种:

  1. Serial Dispatch Queue (等待现在执行中处理结束)
  2. Concurrent Dispatch Queue (不等待现在执行中处理结束)

Concurrent Dispatch Queue 并行执行的处理数受以下因素影响:

  1. Dispatch Queue 中的处理数
  2. CPU内核数
  3. CPU负荷

并行执行,就是使用多个线程同时执行多个处理。如下图。


83913AF6-8DB2-4AA1-A09A-4D80038768CF.png

如何才都能得到以上提到的两种 Dispatch Queue,有两种方法。(往下看)

3.2.2 dispatch_queue_create (方法1)

// 生成 Serial Dispatch Queue
dispatch_queue_t mySerialDispatchQueue = dispatch_queue_create("这个字符串用来标记这个线程,根据开发需要命名", NULL);
// 生成 Concurrent Dispatch Queue
dispatch_queue_t myConcurrentDispatchQueue = dispatch_queue_create("这个字符串用来标记这个线程,根据开发需要命名", DISPATCH_QUEUE_CONCURRENT);
  • 多个 Serial Dispatch Queue 可并发执行。
  • 系统对于一个 Serial Dispatch Queue 就只能生成并使用一个线程,如果生成2000个 Serial Dispatch Queue,那么就是生成2000个线程。
  • 如果过多使用多线程,就会消耗大量内存,引起大量的上下文切换,大幅度降低系统的响应性能。
    (todo: 写一下关于上下文切换的帖子)

生成的 Dispatch Queue 需要程序员负责释放。
通过 dispatch_queue_create 生成的 Dispatch Queue 由 dispatch_release 函数释放。

dispatch_release(myConcurrentDispatchQueue); // 非arc的环境下

3.2.3 Main Dispatch Queue / Global Dispatch Queue (方法2)

获取系统标准提供的 Dispatch Queue。
比方法1更为方便快捷

    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        // 可并行执行的处理
        dispatch_async(dispatch_get_main_queue(), ^{
            // 只能在主线程中执行的处理
        });
    });

这里的 DISPATCH_QUEUE_PRIORITY_DEFAULT 宏定义如下,第一个参数通常直接填 0。

#define DISPATCH_QUEUE_PRIORITY_HIGH 2
#define DISPATCH_QUEUE_PRIORITY_DEFAULT 0
#define DISPATCH_QUEUE_PRIORITY_LOW (-2)
#define DISPATCH_QUEUE_PRIORITY_BACKGROUND INT16_MIN

3.2.4 dispatch_set_target_queue

用来变更Dipatch Queue的优先级。

    dispatch_queue_t mySerialDispatchQueue = dispatch_queue_create("这个字符串用来标记这个线程,根据开发需要命名", NULL);
    dispatch_queue_t globalDispatchQueueBackground = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_BACKGROUND, 0);
    // mySerialDispatchQueue 的优先级变为 DISPATCH_QUEUE_PRIORITY_BACKGROUND
    dispatch_set_target_queue(mySerialDispatchQueue, globalDispatchQueueBackground); 

3.2.5 dispatch_after

跟定时器差不多,不准确,有可能等待时间大于3秒,这是受当前 Main Dispatch Queue 是否繁忙影响。

    dispatch_time_t time = dispatch_time(DISPATCH_TIME_NOW, 3ull * NSEC_PER_SEC);
    dispatch_after(time, dispatch_get_main_queue(), ^{
        NSLog(@"waited at last three seconds");
    });

第二个参数指定要追加处理的 Dispatch Queue。
第一个参数是 dispatch_time_t 类型。

/* dispatch_time 生成 dispatch_time_t 所需的第一个参数 */
#define DISPATCH_TIME_NOW (0ull)
#define DISPATCH_TIME_FOREVER (~0ull)

3.2.6 Dispatch Group

dispatch_group_notify

在所有追加进去的处理都结束了之后,在主线程执行处理。

    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    dispatch_group_t group = dispatch_group_create();
    
    dispatch_group_async(group, queue, ^{NSLog(@"blk0");});
    dispatch_group_async(group, queue, ^{NSLog(@"blk1");});
    dispatch_group_async(group, queue, ^{NSLog(@"blk2");});

    // dispatch_group_notify 第一个参数为要监视的 Dispatch Group,
    // 将第三个参数的 Block 追加到 第二个参数的 Dispatch Queue 中。
    dispatch_group_notify(group, dispatch_get_main_queue(), ^{
        NSLog(@"done");
    });
    dispatch_release(group);

输出结果:

blk1
blk2
blk0
done

dispatch_group_wait

    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    dispatch_group_t group = dispatch_group_create();

    dispatch_group_async(group, queue, ^{NSLog(@"blk0");});
    dispatch_group_async(group, queue, ^{NSLog(@"blk1");});
    dispatch_group_async(group, queue, ^{NSLog(@"blk2");});

    dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
    dispatch_release(group);

从字面上就能理解,dispatch_group_wait 的第二个参数表示等待的时间,DISPATCH_TIME_FOREVER 意味着永久等待。

    dispatch_time_t time = dispatch_time(DISPATCH_TIME_NOW, 1ull * NSEC_PER_SEC);
    long result = dispatch_group_wait(group, time);
    if (result == 0) {
        // 属于 Dispatch Group 的全部处理执行结束
    } else {
        // 还在执行
    }

dispatch_group_wait 的第二个参数为等待的时间(超时时间)。
如果在这个时间之后,result == 0,说明追加进去的处理都执行结束了。
如果 dispatch_group_wait 第二个参数的time为 DISPATCH_TIME_NOW,就不用任何等待就可以判定属于 Dipatch Group 的处理是否执行结束。

3.2.7 dispatch_barrier_async

书本在这一小节里提及最多的就是数据的读写,数据竞争等问题。

    dispatch_queue_t queue = dispatch_queue_create("com.example.gcd.ForBarrier", DISPATCH_QUEUE_CONCURRENT);
    dispatch_async(queue, blk0_for_reading);
    dispatch_async(queue, blk1_for_reading);
    dispatch_async(queue, blk2_for_reading);
    dispatch_async(queue, blk3_for_reading);
    dispatch_barrier_async(queue, blk_for_writing);
    dispatch_async(queue, blk4_for_reading);
    dispatch_async(queue, blk5_for_reading);
    dispatch_async(queue, blk6_for_reading);
    dispatch_async(queue, blk7_for_reading);
A6006FEF-E926-4EDD-8FE1-22BA7E44E992.png

3.2.8 dispatch_sync

dispatch_sync 是简易版的 dispatch_group_wait 函数。
容易因此死锁,尽量避免使用吧。

3.2.9 dispatch_apply

该函数按指定的次数将指定的 Block 追加到指定的 Dispatch Queue 中,并等待全部处理执行结束。

    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    dispatch_apply(10, queue, ^(size_t index) {
        NSLog(@"%zu", index);
    });
    NSLog(@"done");

执行结果

4
1
0
3
5
2
6
8
9
7
done

dispatch_apply 会等待全部处理执行结束。
第一个参数为重复次数,第二个参数为追加对象的 Dispatch Queue,第三个参数为追加的处理。


因为 dispath_apply 与 dispatch_sync 相同,会等待处理执行结束,因此推荐在 dispatch_async 函数中非同步地执行 dispatch_apply 函数。

    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    dispatch_async(queue, ^{
        
        dispatch_apply([array count], queue, ^(size_t index) {
            
            // 在这里处理数组里边的元素
        });
        
        dispatch_async(dispatch_get_main_queue(), ^{
            
            NSLog(@"done");
        });
    });

3.2.10 dispatch_suspend / dispatch_resume

dispatch_suspend 函数挂起指定的 Dispatch Queue。
dispatch_resume 函数恢复指定的 Dispatch Queue。

这些函数对已经执行的处理没有影响。

3.2.11 Dispatch Semaphore

这么理解,通过 dispatch_semaphore_create 创建的 semaphore 有一个计数器(第一个参数),而 dispatch_semaphore_wait 函数在遇到 semphore(第一个参数) 大于等于1的情况下才能继续往下执行,dispatch_semaphore_signal 函数可以给 semphore 的计数器加1。
通过以上方式可以进行排异处理,仔细体会以下代码。

    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
    NSMutableArray *array = [NSMutableArray array];
    for (int i = 0; i < 1000; ++i) {
        dispatch_async(queue, ^{
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            [array addObject:[NSNumber numberWithInt:i]];
            dispatch_semaphore_signal(semaphore);
        });
    }

3.2.12 dispatch_once

用来创建单例。

    static dispatch_once_t pred;
    dispatch_once(&pred, ^{
        // 初始化
    });

3.2.13 Dispatch I/O
同多 Dispatch I/O 读写文件时,使用 Global Dispatch Queue 将1个文件按某个大小 read/write。

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

推荐阅读更多精彩内容

  • Grand Central Dispatch(GCD)概要 我的博客链接 什么是GCD? 苹果官方这么描述的:Gr...
    换个名字再说阅读 1,291评论 4 7
  • Dispatch Queue 首先回顾一下苹果GCD的说明 开发者要做的只是定义想执行的任务并追加到适当的Disp...
    面试小集阅读 1,521评论 0 4
  • 最近颇花了一番功夫把多线程GCD人的一些用法总结出来,一来帮自己巩固一下知识、二来希望能帮到对这一块还迷茫...
    人活一世阅读 290评论 1 1