美文网首页面试宝点
dispatch_group_t 和 dispatch_barr

dispatch_group_t 和 dispatch_barr

作者: 再好一点点 | 来源:发表于2019-03-23 14:20 被阅读0次

    平时在进行多线程处理任务时,有时候希望多个任务之间存在着一种联系,希望在所有的任务执行完后做一些总结性处理。
    那么就可以将多个任务放在一个任务组中进行统一管理。dispatch提供了相应的API供我们完成这一需求。

    一、dispatch_group_t 相关属性介绍

    1.dispatch_group_async(group, queue, block);
    将block任务添加到queue队列,并被group组管理

    2.dispatch_group_enter(group);
    声明dispatch_group_enter(group)此行下面的任务由group组管理,group组的任务数+1

    3.dispatch_group_leave(group);
    相应的任务执行完成,group组的任务数-1

    4.dispatch_group_create();
    创建一个group组

    5.dispatch_group_wait(group1, DISPATCH_TIME_FOREVER);
    当前线程暂停,等待dispatch_group_wait(group1, DISPATCH_TIME_FOREVER)上面的任务执行完成后,线程才继续执行。

    6.dispatch_group_notify(group1, queue1,block);
    监听group组中任务的完成状态,当所有的任务都执行完成后,触发block块,执行总结性处理。

    1、常见用法的区别

    在使用group组处理任务时,常见的有两种组合。

    第一种:

    dispatch_group_async(group, queue, block);
    dispatch_group_notify(group, queue, block);

    dispatch_queue_t queue1 = dispatch_queue_create("com.yahui.dispatch_group_test", DISPATCH_QUEUE_CONCURRENT);
        dispatch_group_t group1 = dispatch_group_create();
        
        dispatch_group_async(group1, queue1, ^{
            for (NSInteger i =0; i<3; i++) {
                sleep(1);
                NSLog(@"%@-同步任务执行-:%ld",@"任务1",(long)i);
            }
        });
        
        dispatch_group_async(group1, queue1, ^{
            for (NSInteger i =0; i<3; i++) {
                sleep(1);
                NSLog(@"%@-同步任务执行-:%ld",@"任务2",(long)i);
            }
        });
        
        //       方式1(不好,会卡住当前线程)
        //        dispatch_group_wait(group2, DISPATCH_TIME_FOREVER);
        
        //方式2(比较好)等待上面的任务全部完成后,会收到通知执行block中的代码 (不会阻塞线程)
        dispatch_group_notify(group1, queue1, ^{
            NSLog(@"Method1-全部任务执行完成");
        });
    

    同步任务运行结果:

    2019-03-23 14:08:42.689755+0800 Test[66995:3818419] 任务1-同步任务执行-:0
    2019-03-23 14:08:42.689755+0800 Test[66995:3818417] 任务2-同步任务执行-:0
    2019-03-23 14:08:43.695026+0800 Test[66995:3818417] 任务2-同步任务执行-:1
    2019-03-23 14:08:43.695039+0800 Test[66995:3818419] 任务1-同步任务执行-:1
    2019-03-23 14:08:44.699468+0800 Test[66995:3818419] 任务1-同步任务执行-:2
    2019-03-23 14:08:44.699478+0800 Test[66995:3818417] 任务2-同步任务执行-:2
    2019-03-23 14:08:44.699707+0800 Test[66995:3818419] Method1-全部任务执行完成
    
    第二种:

    dispatch_group_enter(group);
    dispatch_group_leave(group);
    dispatch_group_notify(group, queue,block);

    dispatch_queue_t queue2 = dispatch_queue_create("com.yahui.dispatch_group_test", DISPATCH_QUEUE_CONCURRENT);
        dispatch_group_t group2 = dispatch_group_create();
        
        dispatch_group_enter(group2);
        dispatch_async(queue2, ^{
            for (NSInteger i =0; i<3; i++) {
                sleep(1);
                NSLog(@"%@-异步任务执行-:%ld",@"任务1",(long)i);
                
            }
            dispatch_group_leave(group2);
        });
        
        dispatch_group_enter(group2);
        dispatch_async(queue2, ^{
            for (NSInteger i =0; i<3; i++) {
                sleep(1);
                NSLog(@"%@-异步任务执行-:%ld",@"任务2",(long)i);
            }
            dispatch_group_leave(group2);
        });
    
    //        方式1(不好,会卡住当前线程)
    //        dispatch_group_wait(group2, DISPATCH_TIME_FOREVER);
    
        //方式2(比较好)等待上面的任务全部完成后,会收到通知执行block中的代码 (不会阻塞线程)
        dispatch_group_notify(group2, queue2, ^{
            NSLog(@"Method2-全部任务执行完成");
        });
    

    异步任务执行结果:

    2019-03-23 14:17:23.074808+0800 Test[67208:3855402] 任务1-异步任务执行-:0
    2019-03-23 14:17:23.074808+0800 Test[67208:3855403] 任务2-异步任务执行-:0
    2019-03-23 14:17:24.075744+0800 Test[67208:3855402] 任务1-异步任务执行-:1
    2019-03-23 14:17:24.075744+0800 Test[67208:3855403] 任务2-异步任务执行-:1
    2019-03-23 14:17:25.076215+0800 Test[67208:3855403] 任务2-异步任务执行-:2
    2019-03-23 14:17:25.076215+0800 Test[67208:3855402] 任务1-异步任务执行-:2
    2019-03-23 14:17:25.076442+0800 Test[67208:3855402] Method2-全部任务执行完成
    
    二:dispatch_barrier_async
    dispatch_queue_t queue = dispatch_queue_create("com.yahui.queue", DISPATCH_QUEUE_CONCURRENT);
        dispatch_async(queue, ^{
            for (int i = 0; i < 2; i++) {
                sleep(1);
                NSLog(@"任务1 %d", i);//例如读文件
            }
        });
        
        dispatch_async(queue, ^{
            for (int i = 0; i < 2; i++) {
                sleep(1);
                NSLog(@"任务2 %d", i);/例如读文件
            }
        });
    
        dispatch_barrier_async(queue, ^{
            for (int i = 0; i < 2; i++) {
                sleep(1);
                NSLog(@"任务3 %d", i);//例如写文件
            }
        });
        
        dispatch_async(queue, ^{
            for (int i = 0; i < 2; i++) {
                sleep(1);
                NSLog(@"任务4 %d", i);/例如读文件
            }
        });
        
        dispatch_async(queue, ^{
            for (int i = 0; i < 2; i++) {
                sleep(1);
                NSLog(@"任务5 %d", i);/例如读文件
            }
        });
    

    执行结果:

    2019-03-23 15:14:38.267893+0800 Test[68536:4015385] 任务2 0
    2019-03-23 15:14:38.267893+0800 Test[68536:4015381] 任务1 0
    2019-03-23 15:14:39.272975+0800 Test[68536:4015381] 任务1 1
    2019-03-23 15:14:39.272975+0800 Test[68536:4015385] 任务2 1
    2019-03-23 15:14:40.276721+0800 Test[68536:4015385] 任务3 0
    2019-03-23 15:14:41.282023+0800 Test[68536:4015385] 任务3 1
    2019-03-23 15:14:42.283843+0800 Test[68536:4015385] 任务4 0
    2019-03-23 15:14:42.283848+0800 Test[68536:4015381] 任务5 0
    2019-03-23 15:14:43.284249+0800 Test[68536:4015381] 任务5 1
    2019-03-23 15:14:43.284258+0800 Test[68536:4015385] 任务4 1
    

    可以看到dispatch_barrier_async的作用可以用一个词概括--承上启下,它保证此前的任务都先于自己执行,此后的任务也迟于自己执行。本例中,任务3会在任务1、2都执行完之后执行,而任务4、5会等待任务3执行完后执行。

    应用场景
    dispatch_group类似,dispatch_barrier也是异步任务间的一种同步方式,可以在比如文件的读写操作时使用,保证读操作的准确性。

    另外,有一点需要注意,dispatch_barrier_syncdispatch_barrier_async只在自己创建的并发队列上有效,在全局(Global)并发队列、串行队列上,效果跟dispatch_(a)sync效果一样。

    相关文章

      网友评论

        本文标题:dispatch_group_t 和 dispatch_barr

        本文链接:https://www.haomeiwen.com/subject/oyksvqtx.html