iOS用dispatch_group_t监听多个异步请求全部返回和多任务下载

提起ios中多个异步函数后的同步问题，自然会想到 dispatch group 这个概念，那么它能够解决异步网络请求的问题吗？

对于dispatch多个异步操作后的同步方法，以前只看过dispatch_group_async，看看这个方法的说明：

@discussion
Submits a block to a dispatch queue and associates the block with the given
dispatch group. The dispatch group may be used to wait for the completion
of the blocks it references.
可以看出，dispatch_group_async，是用于同步工作的，但是，它的判断标准是放入的block是否执行完毕，如果我们放入block中包含异步的网络请求，这个方法无法在网络数据返回后再进行同步。

看一段使用dispatch_group_async处理网络问题的代码：

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view, typically from a nib.
    
    NSURLSession *session = [NSURLSession sharedSession];
    
    dispatch_queue_t dispatchQueue = dispatch_queue_create("test.queue", DISPATCH_QUEUE_CONCURRENT);
    dispatch_group_t dispatchGroup = dispatch_group_create();
    dispatch_group_async(dispatchGroup, dispatchQueue, ^(){
        
        NSURLSessionDataTask *task = [session dataTaskWithURL:[NSURL URLWithString:@"https://www.baidu.com"] completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"got data from internet1");
        }];
        [task resume];
    });
    dispatch_group_async(dispatchGroup, dispatchQueue, ^(){
        NSURLSessionDataTask *task = [session dataTaskWithURL:[NSURL URLWithString:@"https://www.baidu.com"] completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"got data from internet2");
        }];
        [task resume];
    });
    
    dispatch_group_notify(dispatchGroup, dispatch_get_main_queue(), ^(){
        NSLog(@"end");
    });
}

看看log的输出：

2016-07-13 17:42:55.170 aaaa[4797:295528] end
2016-07-13 17:42:55.322 aaaa[4797:295574] got data from internet2
2016-07-13 17:42:55.375 aaaa[4797:295574] got data from internet1
完全没有达到效果。这是因为这里的网络请求是个异步的方法，没有等待具体的数据返回，放入的dispatch queue的 block就执行完毕了。所以没收到2个网络数据，就提前调用了dispatch_group_notify指定的结束方法。

看完了错误的方法，再看看正确的方法：

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view, typically from a nib.
    
    NSURLSession *session = [NSURLSession sharedSession];
    
    dispatch_queue_t dispatchQueue = dispatch_queue_create("test.queue", DISPATCH_QUEUE_CONCURRENT);
    dispatch_group_t dispatchGroup = dispatch_group_create();
    // dispatch_group_async(dispatchGroup, dispatchQueue, ^(){
    
    dispatch_group_enter(dispatchGroup);
    
    NSURLSessionDataTask *task = [session dataTaskWithURL:[NSURL URLWithString:@"https://www.baidu.com"] completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
        NSLog(@"got data from internet1");
        
        dispatch_group_leave(dispatchGroup);
    }];
    [task resume];
    
    //  });
    //  dispatch_group_async(dispatchGroup, dispatchQueue, ^(){
    dispatch_group_enter(dispatchGroup);
    
    NSURLSessionDataTask *task2 = [session dataTaskWithURL:[NSURL URLWithString:@"https://www.baidu.com"] completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
        NSLog(@"got data from internet2");
        
        dispatch_group_leave(dispatchGroup);
    }];
    [task2 resume];
    // });
    
    dispatch_group_notify(dispatchGroup, dispatch_get_main_queue(), ^(){
        NSLog(@"end");
    });
}

看正确是输出结果：

2016-07-13 17:46:10.282 aaaa[4847:300370] got data from internet1
2016-07-13 17:46:10.501 aaaa[4847:300370] got data from internet2
2016-07-13 17:46:10.502 aaaa[4847:300341] end
相对于简单的dispatch_group_async，dispatch_group_enter 和 dispatch_group_leave 可以对group进行更细致的处理。

我们看看关于dispatch_group_enter 的具体说明

Calling this function increments the current count of outstanding tasks in the group. Using this function (with dispatch_group_leave) allows your application to properly manage the task reference count if it explicitly adds and removes tasks from the group by a means other than using the dispatch_group_async function. A call to this function must be balanced with a call to dispatch_group_leave. You can use this function to associate a block with more than one group at the same time.

简单的说，就是dispatch_group_enter会对group的内部计数加一，dispatch_group_leave会对group的内部计数减一，就类似以前的retain和release方法。说白了也是维护了一个计数器。

以前我的做法就是自己维护计数器。在发送网络请求前，记下发送总数，数据返回后，在同一个thread中（或者在一个DISPATCH_QUEUE_SERIAL类型的dispatch_queue中），对计数器进行+1操作，当计数器和网络请求数相等时，调用最后的处理。

相比自己的处理的计数器，dispatch_group_enter 处理方法可能显得更正规一些，代码更规范了，但执行效果是一样的。。。

今天再改其他的工程的时候，又遇到了这个问题，有一个值，需要2个异步操作查询回2个值进行计算，因此必须再2个异步操作结束后才能进行计算操作。开始试着使用了OperationQueue，想用addDependency方法，但是这个方法无法灵活地控制，只适合block内容已经确定的情况。对于我遇到的这种异步操作，block的内容是不定的，需要依赖异步的返回，用operation queue会遇到各种问题，无法解决问题，十分复杂！

今天看到了dispatch_barrier_async函数，说明如下

Calls to this function always return immediately after the block has been submitted and never wait for the block to be invoked. When the barrier block reaches the front of a private concurrent queue, it is not executed immediately. Instead, the queue waits until its currently executing blocks finish executing. At that point, the barrier block executes by itself. Any blocks submitted after the barrier block are not executed until the barrier block completes.
The queue you specify should be a concurrent queue that you create yourself using the dispatch_queue_create function. If the queue you pass to this function is a serial queue or one of the global concurrent queues, this function behaves like the dispatch_async function.

简单地说，就是在这个函数之前被提交到quque里的block一定会被先执行，之后执行dispatch_barrier_async设定的block，最后执行调用dispatch_barrier_async之后才提交到queue里的block。

开始以为这个函数能够处理我们的问题，结果是不行的，先看看测试用的代码：

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view, typically from a nib.
    
    NSURLSession *session = [NSURLSession sharedSession];
    
    dispatch_queue_t dispatchQueue = dispatch_queue_create("test.queue", DISPATCH_QUEUE_CONCURRENT);
 
    dispatch_async(dispatchQueue, ^{
        NSURLSessionDataTask *task = [session dataTaskWithURL:[NSURL URLWithString:@"https://www.baidu.com"] completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"got data from internet1");
        }];
        
        [task resume];
    });
 
    dispatch_async(dispatchQueue, ^{
        NSURLSessionDataTask *task2 = [session dataTaskWithURL:[NSURL URLWithString:@"https://www.baidu.com"] completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"got data from internet2");         
        }];
        [task2 resume];
    });
   
    dispatch_barrier_async(dispatchQueue, ^{
        NSLog(@"================== barrier block is called");
    });
    
    dispatch_async(dispatchQueue, ^{
        NSLog(@"=========the last block is called");
    });  
}

这段代码的输出结果是：

2016-07-17 14:34:46.620 aaaaa[5000:91010] ================== barrier block is called
2016-07-17 14:34:46.621 aaaaa[5000:91010] =========the last block is called
2016-07-17 14:34:46.815 aaaaa[5000:91010] got data from internet1
2016-07-17 14:34:46.866 aaaaa[5000:91014] got data from internet2
完全没有达到2个网络请求都返回后，再执行the last block的效果。

原因和 dispatch_group_async无法达到目的的原因是一样的：它认为一个block返回后就是逻辑结束了，就会继续执行其他代码，对于block中异步返回的网络数据，没有对应的处理手段。

NSUrlSession 不是用的 NSOperation Queue 吗，能不能直接利用Operation Queue 而不是dispatch_queue 来解决这个问题呢？

我们知道NSOperation中有addDependency这个方法，我们能不能把几个网络请求分别封装一下：

[NSBlockOperation blockOperationWithBlock:^{
        NSURLSessionDataTask *task = [session dataTaskWithURL:[NSURL URLWithString:@"https://www.baidu.com"] completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"got data from internet1");
        }];
        [task resume];
    }];

这样，再添加依赖，来达到效果呢？

结论是：仅仅使用NSBlockOperation来构建operation是不可以的。这里的错误原因和使用dispatch_group_async是一样的。

但是，如果把NSUrlConnection的请求封装成NSOperation子类，使这个子类有这个效果："当网络数据返回时，才算这个operation的结束"，就可以利用这个子类和nsoperationqueue 达到我们的目的！

(题外话：NSOperationQueue 就不同于dispatch_queue了，它没有dispatch_queue中的并行，串行类型，但是，有个类似功能的属性maxConcurrentOperationCount，当maxConcurrentOperationCount = 1时，自然就是串行的了。）

总结使用urlsession 进行下载的通用方法，这个方法加入了对最大并发数的限制，也加入了全部完成后的回调，基本可以应对任何情况的下载了！

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view, typically from a nib.

    dispatch_semaphore_t semaphore = dispatch_semaphore_create(3);    
    dispatch_group_t dispatchGroup = dispatch_group_create();
    
    for (int i = 0; i < 10; i++) 
    {        
        NSLog(@"i is %d",i);
        NSURLSession *session = [NSURLSession sharedSession];
        NSURL *url = [NSURL URLWithString:@"https://codeload.github.com/EricForGithub/SalesforceReactDemo/zip/master"];
        NSURLSessionDownloadTask *sessionDownloadTask =[session downloadTaskWithURL:url completionHandler:^(NSURL * _Nullable location, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            sleep(5.0);
            NSLog(@"release a signal");
            dispatch_group_leave(dispatchGroup);
            dispatch_semaphore_signal(semaphore);
        }];
        
         dispatch_group_enter(dispatchGroup);//为了所有下载完成后能调用函数，引入 dispatch group。如果信号量是1的话，可以不使用这个机制，也能达到效果。
         dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); //为了最大并发数，加入信号量机制
         [sessionDownloadTask resume];
    }
    
    dispatch_group_notify(dispatchGroup, dispatch_get_main_queue(), ^(){
        NSLog(@"end");
    });   
}

参考来源：http://www.cnblogs.com/breezemist/p/5667776.html

iOS用dispatch_group_t监听多个异步请求全部返回和多任务下载

推荐阅读更多精彩内容