GCD group 的使用

group 头文件中函数的解析:


/*
OS_OBJECT_DECL(dispatch_object);
#define DISPATCH_DECL(name)  OS_OBJECT_DECL_SUBCLASS(name, dispatch_object)
*/
// 从上面可以看出  dispatch_group 是  dispatch_object 子类
DISPATCH_DECL(dispatch_group);

dispatch_group_t ==  DISPATCH_DECL(dispatch_group);


/*
 创建一个组, 创建的组可能与 block 相关联。
 这个调度组能够被用来等待他引用的 block 的完成。
  - result : 一个新的组。 在失败的情况下返回 NULL
*/
dispatch_group_t
dispatch_group_create(void);


/**
调度组 在 queue 异步执行 block
*/
void
dispatch_group_async(
    dispatch_group_t group,            // 调度组对象
    dispatch_queue_t queue,            // 队列
    dispatch_block_t block             // block
);           

/**
调度组 在 queue 异步执行 函数
*/
void
dispatch_group_async_f(
    dispatch_group_t     group,          // 调度组对象
    dispatch_queue_t     queue,          // 队列
    void                 *context,       // 上下文(传递给函数的)
    dispatch_function_t  work            // 函数
);


long
dispatch_group_wait(dispatch_group_t group, dispatch_time_t timeout);

// 组中异步执行任务全部执行完成的通知
void
dispatch_group_notify(
    dispatch_group_t group,       // 队列组
    dispatch_queue_t queue,       // 执行任务的队列
    dispatch_block_t block);      // 任务 


// 组中异步执行的函数全部执行的通知
void
dispatch_group_notify_f(
    dispatch_group_t group,                  // 队列组
    dispatch_queue_t queue,                  // 执行任务的队列   
    void *context,                           // 上下文
    dispatch_function_t work);               // 函数

// 入组函数
void
dispatch_group_enter(dispatch_group_t group);

// 出组函数
void
dispatch_group_leave(dispatch_group_t group);

调度组在项目中的使用(调度组的基本使用)

调度组:
调度组是用来协调一个或多个任务提交到队列异步触发的。 应用程序可以使用调度组等待所有调度组中的所有任务的完成。

所有异步队列执行完毕后得到一个通知。
**场景: **
a 异步下载任务,b 异步下载任务, c 异步下载任务。
只有在 a, b, c 三个异步下载任务全部完成的情况下。才通知主线程刷新界面。亦可以通知某个队列执行其他的操作。

NSLog(@"before: %@", [NSThread currentThread]);

// 创建一个组 (获得一个新的,空的调度组)
dispatch_group_t g =  dispatch_group_create();

// 将队列关联组
dispatch_group_async(g, dispatch_get_global_queue(0, 0), ^{
    NSLog(@"taskA: %@", [NSThread currentThread]);
});

// 将队列关联组
dispatch_group_async(g, dispatch_get_global_queue(0, 0), ^{
    NSLog(@"taskB: %@", [NSThread currentThread]);
});

// 将队列关联组
dispatch_group_async(g, dispatch_get_global_queue(0, 0), ^{
    NSLog(@"taskC: %@", [NSThread currentThread]);
});

// 组中的队列全部执行完毕后就通知调度组
dispatch_group_notify(g, dispatch_get_main_queue(), ^{
    NSLog(@"MainTask: %@", [NSThread currentThread]);
});


 NSLog(@"after: %@", [NSThread currentThread]);


// 打印结果
2016-06-23 09:12:05.162 Thread-Objc[9371:984276] before: <NSThread: 0x7f8c437028a0>{number = 1, name = main}
2016-06-23 09:12:05.163 Thread-Objc[9371:984276] after: <NSThread: 0x7f8c437028a0>{number = 1, name = main}
2016-06-23 09:12:05.163 Thread-Objc[9371:984320] taskA: <NSThread: 0x7f8c43712610>{number = 2, name = (null)}
2016-06-23 09:12:05.163 Thread-Objc[9371:984328] taskC: <NSThread: 0x7f8c43500a80>{number = 4, name = (null)}
2016-06-23 09:12:05.163 Thread-Objc[9371:984323] taskB: <NSThread: 0x7f8c4376ada0>{number = 3, name = (null)}
2016-06-23 09:12:05.167 Thread-Objc[9371:984276] MainTask: <NSThread: 0x7f8c437028a0>{number = 1, name = main}

上面的代码是一个简单的使用方式。

调度组的使用的原理解析
打开终端输入

// 使用这个命令可以查看 GCD 的详细文档
$ man dispatch

// 查看和 group 相关的文档
$ man dispatch_group_create

文档示例
(官方文档的说明)

// dispatch_group_async() 函数的操作和下面是等价的:
The dispatch_group_async() convenience function behaves like so:

void
dispatch_group_async(dispatch_group_t group, dispatch_queue_t queue, dispat
ch_block_t block)
{
             // 引用计数器加1
             dispatch_retain(group);

            // 入组
             dispatch_group_enter(group);

            // 任务异步执行
             dispatch_async(queue, ^{

                      // 执行任务
                     block();

                     // 出组(通知组,任务执行完毕)
                     dispatch_group_leave(group);
                     
                     // 引用计数器减1 
                     dispatch_release(group);
        });
}

示例代码改写

NSLog(@"before: %@", [NSThread currentThread]);

dispatch_group_t g =  dispatch_group_create();


dispatch_group_enter(g);

dispatch_async(dispatch_get_global_queue(0, 0), ^{
    
    NSLog(@"taskA: %@", [NSThread currentThread]);
    
    dispatch_group_leave(g);
});



dispatch_group_enter(g);

dispatch_async(dispatch_get_global_queue(0, 0), ^{
    
    NSLog(@"taskB: %@", [NSThread currentThread]);
    
    dispatch_group_leave(g);
});



dispatch_group_enter(g);

dispatch_async(dispatch_get_global_queue(0, 0), ^{
    
    NSLog(@"taskC: %@", [NSThread currentThread]);
    
    dispatch_group_leave(g);
});


dispatch_group_notify(g, dispatch_get_main_queue(), ^{
    NSLog(@"MainTask: %@", [NSThread currentThread]);
});


NSLog(@"after: %@", [NSThread currentThread]);

// 打印结果
2016-06-23 09:35:52.744 Thread-Objc[9540:1004789] before: <NSThread: 0x7fdec3d04920>{number = 1, name = main}
2016-06-23 09:35:52.744 Thread-Objc[9540:1004789] after: <NSThread: 0x7fdec3d04920>{number = 1, name = main}
2016-06-23 09:35:52.745 Thread-Objc[9540:1004833] taskA: <NSThread: 0x7fdec3d11d30>{number = 2, name = (null)}
2016-06-23 09:35:52.745 Thread-Objc[9540:1004829] taskC: <NSThread: 0x7fdec3c09fa0>{number = 3, name = (null)}
2016-06-23 09:35:52.745 Thread-Objc[9540:1004822] taskB: <NSThread: 0x7fdec3d09a50>{number = 4, name = (null)}
2016-06-23 09:35:52.749 Thread-Objc[9540:1004789] MainTask: <NSThread: 0x7fdec3d04920>{number = 1, name = main}


/*
 dispatch_group_enter(g); 操作都在 g 所在线程。 
 即当前线程, 在进行异步操作之前, dispatch_group_enter(g) 都已经全部执行完毕。

 g 中已经完整的记录了 block 的个数。

 追踪 NSLog(@"after: %@", [NSThread currentThread]); 的打印可以知道。
 
 执行一次 dispatch_group_enter(g) 操作,block 在组中的记录就会 加 1 。
 在子线程中执行一次 dispatch_group_leave(g); 会使 block 在组中的记录就会 减 1 。
 
 当组中的 block 记录的值为 0 的时候,就会调用 dispatch_group_notify() 函数。
 
 */



理解上面的实例后,对于 GCD 中的组基本的学习已经差不多了


细节知识点说明:

dispatch_group_enter();dispatch_group_leave(); 必须成对使用。 这两个函数会更新 block 在组中的数量。

在这个示例中除了 dispatch_group_waitdispatch_group_async_f 基本都用了一遍。
dispatch_group_async_f 是函数调用的基本不用。

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

推荐阅读更多精彩内容