美文网首页IOS知识积累
dispatch_group_notify、dispatch_g

dispatch_group_notify、dispatch_g

作者: 小蜗牛吱呀之悠悠 | 来源:发表于2017-11-23 22:02 被阅读105次
以下所有内容均为个人观点,转载请注明出处<简书--小蜗牛吱呀之悠悠 >,谢谢!

最近在编码一个多重网络请求,必须等所有请求结束才能最终返回结果,与此同时,请求涉及多次同步异步来回问题。经过不断的demo验证,得出下文观点,为了方便以后的总结,同时也希望能对给予大家一定的启发,故写下这篇博客,若有不恰当之处敬请留言指导,不胜感激,话不多说,开始正文!

1、dispatch_group_notify的理解与使用

dispatch_group_notify通常分为同步与异步,同步的情况可以结合dispatch_group_wait一同使用,但是dispatch_group_wait会阻塞当前线程(所以不能放在主线程调用)。
dispatch_group_notify用于异步时,会等待group中的所有任务执行完毕后才执行自身的block,group中的线程可以是同步的,也可以是异步的,可以是自建队列,也可以是系统的global队列,用法如下:

dispatch_group_t group = dispatch_group_create();
    for (int i = 0; i < 3; i ++){
        dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
            sleep(3);
            NSLog(@"异步任务开启!,当前线程:%@",[NSThread currentThread]);
        });
    }
   dispatch_group_notify(group, dispatch_get_main_queue(), ^(){
        // 主线程处理
        NSLog(@"主线程执行,当前线程:%@",[NSThread currentThread]);
    });

通过系统提供的global方法创建三个子线程,加入group中,受到group管理,睡眠三秒后,打印线程。当group中所有线程的任务都执行完后,会执行自身的block,并打印主线程信息。执行结果如下:


dispatch_group_notify用法.png
2、dispatch_group_notify结合dispatch_group_enter和dispatch_group_leave的使用

dispatch_group_enter和dispatch_group_leave分别表示某个任务进入到group中,受到group管理,在group内部会有一个计数器,调用dispatch_group_enter后,该计数器会+1,调用dispatch_group_leave后该计数器会-1,当计数器为0时,则主动调用dispatch_group_notify的block,否则一直处于等待中,直到所有enter的任务都调用完leave,因此,一个任务真正的执行完的标志是调用了dispatch_group_leave,否则dispatch_group_notify会一直处于等待中,因此,dispatch_group_enter和dispatch_group_leave一定要配套使用。

          dispatch_group_enter(group);
          dispatch_async(dispatch_get_global_queue(0, 0), ^{
             sleep(5);
             NSLog(@"thread:%@ i:%d",[NSThread currentThread]);
             test();
              dispatch_group_leave(group);
          });
          dispatch_group_notify(group, dispatch_get_main_queue(), ^(){
          // 主线程处理
          NSLog(@"主线程执行,当前线程:%@",[NSThread currentThread]);
          });

那么方式1和方式2又有什么区别呢?当任务中包含block时,有可能造成不会回调的情况

3、多次子、主线程来回切换导致dispatch_group_notify在dispatch_group_enter和dispatch_group_leave之前调用问题
   group = dispatch_group_create();
   for (int i = 0; i < 3; i++) {
       [self testBlock:^{
           sleep(3);
           NSLog(@"---thread:%@ i:%d",[NSThread currentThread]);
       }];
   }
   dispatch_group_notify(group, dispatch_get_main_queue(), ^(){
       NSLog(@"notify:任务都完成了");
   });

- (void)testBlock:(Test)test {
       dispatch_group_async(group,dispatch_get_global_queue(0, 0) , ^{
       NSLog(@"---1");
       dispatch_async(dispatch_get_main_queue(), ^{
           dispatch_group_async(group,dispatch_get_global_queue(0, 0) , ^{
               NSLog(@"---2");
               dispatch_async(dispatch_get_main_queue(), ^{
                   dispatch_group_enter(group);
                   dispatch_async(dispatch_get_global_queue(0, 0), ^{
                       sleep(5);
                       NSLog(@"thread:%@ i:%d",[NSThread currentThread]);
                       test();
                       dispatch_group_leave(group);
                   });
               });
           });
       });
   });
}

在一个耗时的网络请求完成后,回到主线程,此时再次进行网络请求,成功后再次回主线程,由于第三次的网络请求是依赖于前两次成功之后才能调用,所有,再次开辟子线程调用。

执行结果:


image.png

结果发现,notify并没有在所有任务都执行完后并且都leave之后再执行,而是在enter之前就执行了,这是为什么呢?原因是多次网络请求中都会回到主线程,在回主线程之前,notify已经在等待了,当请求完毕,在主线程中添加新的任务,并且enter时,enter被放在了notify的执行顺序之后,因此造成了先执行,notify再执行enter。以下是其中一种解决办法:

    group = dispatch_group_create();
    for (int i = 0; i < 3; i++) {
        dispatch_group_enter(group);
        [self testBlock:^{
            sleep(3);
            NSLog(@"---thread:%@ i:%d",[NSThread currentThread]);
        }];
    }
    dispatch_group_notify(group, dispatch_get_main_queue(), ^(){
        NSLog(@"notify:任务都完成了");
    });


- (void)testBlock:(Test)test {
    dispatch_group_async(group,dispatch_get_global_queue(0, 0) , ^{
        NSLog(@"---1");
        dispatch_async(dispatch_get_main_queue(), ^{
            dispatch_group_async(group,dispatch_get_global_queue(0, 0) , ^{
                NSLog(@"---2");
                dispatch_async(dispatch_get_main_queue(), ^{
                    
                    dispatch_async(dispatch_get_global_queue(0, 0), ^{
                        sleep(5);
                        NSLog(@"thread:%@ i:%d",[NSThread currentThread]);
                        test();
                        dispatch_group_leave(group);
                    });
                    
                });
            });
        });
    });
}

执行结果:

image.png

相关文章

网友评论

    本文标题:dispatch_group_notify、dispatch_g

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