组合 Block 的 Dispatch Group

dispatch group 可以把并行执行的多个任务合成一组，于是调用者就可以知道这些任务何时才能全部执行完毕。例如，可以把一系列操作文件的任务或者网络请求的任务添加到 dispatch group 中，等全部完成这些耗时的任务之后再进行下一步操作。
创建 dispatch group 的方式如下：

dispatch_group_t dispatch_group_create(void);

dispatch group 就是个简单的数据结构，这种结构彼此之间没有什么区别，它不像派发队列，后者还有个用来区别身份的标识符。

想把任务编组，有两种方法。第一种是用下面这个函数：

dispatch_group_async(dispatch_group_t group,
    dispatch_queue_t queue,
    dispatch_block_t block);

它是普通 dispatch_async 函数的变体。group 参数用于表示执行的块所归属的组，queue 表示执行任务的队列。所以 dispatch_group_async 可以方便的向 dispatch group 中添加不同队列的不同任务。此函数中的 queue 既可以时串行队列，又可以时并行队列。然而，如果所有任务都排在同一个串行队列里，那么 dispatch group 的用处就不大了，因为只需要在提交完全部任务之后再提交一个块即可。

第二种能够指定任务所属的 dispatch group 的方法是使用下面这一对函数：

void dispatch_group_enter(dispatch_group_t group);
void dispatch_group_leave(dispatch_group_t group);

前者能够使 dispatch group 里正要执行的任务数递增，而后者则使之递减。所以，调用完 dispatch_group_enter 以后，必须有与之对应的 dispatch_group_leave 才行。如果调用 enter 之后，没有相应的 leave 操作，那么这一组任务就永远执行不完。在使用时，可以在向队列中添加任务时调用 enter，在任务执行完成之后合适的地方调用 leave。

当像 group 中添加完所有的任务之后，有两种方式可以等待任务完成。第一种方法是使用下面的函数：

long dispatch_group_wait(dispatch_group_t group, dispatch_time_t timeout);

此函数有两个参数，group 是要等待的线程组，timeout 表示要等待的时间。timeout 参数表示函数在等待 dispatch group 执行完毕时，应该阻塞多久。如果执行 dispatch group 所需的时间小于 timeout，则返回 0，否则返回非 0 值。此参数也可以取常量 DISPATCH_TIME_FOREVER，这表示函数会一直等待 dispatch group 执行完，而不会超时。注意：dispatch_group_wait 是同步的，会阻塞当前线程，所以不能放在主线程执行。

第二种方式时使用下面函数：

void dispatch_group_notify(dispatch_group_t group,
        dispatch_queue_t queue,
        dispatch_block_t block);

与 dispatch_group_wait 不同的是该函数不会阻塞当前线程。开发着可以向此函数传入 block，等 dispatch group 执行完毕之后，block 会在指定的线程上运行。

使用 dispatch_group_wait 的例子：

• object-c

NSLog(@"--- 开始设置任务 ----");
// 因为 dispatch_group_wait 会阻塞线程，所以创建一个新的线程，用来完成任务
// 同时用异步的方式向新线程（tasksQueue）中添加任务
dispatch_queue_t tasksQueue = dispatch_queue_create("tasksQueue", DISPATCH_QUEUE_CONCURRENT);
dispatch_async(tasksQueue, ^{
    // 真正用来完成任务的线程
    dispatch_queue_t performTasksQueue = dispatch_queue_create("performTasksQueue", DISPATCH_QUEUE_CONCURRENT);
    dispatch_group_t group = dispatch_group_create();
    for (int i = 0; i < 3; i++) {
        // 入组之后的 block 会被 group 监听
        // 注意：dispatch_group_enter 一定和 dispatch_group_leave 要配对出现
        dispatch_group_enter(group);
        dispatch_async(performTasksQueue, ^{
            NSLog(@"开始第 %zd 项任务", i);
            [NSThread sleepForTimeInterval:(3 - i)];
            dispatch_group_leave(group);
            NSLog(@"完成第 %zd 项任务", i);
        });
    }
    dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
    dispatch_async(dispatch_get_main_queue(), ^{
        NSLog(@"全部任务完成");
    });
});
NSLog(@"--- 结束设置任务 ----");

• swift 3.0

print("--- 开始设置任务 ----");
DispatchQueue.main.async {
    let group = DispatchGroup.init()
    let tasksQueue = DispatchQueue.init(label: "tasksQueue", qos: .default, attributes: .concurrent, autoreleaseFrequency: .inherit, target: nil)
    for i in 0..<3 {
        group.enter()
        tasksQueue.async {
            print("开始第 \(i) 项任务")
            sleep(UInt32(3 - i))
            print("结束第 \(i) 项任务")
            group.leave()
        }
    }
    //
    let result = group.wait(timeout: DispatchTime.distantFuture)
    if result == .success {
        print("全部任务完成")
    } else {
        print("任务执行超时")
    }
}
print("--- 开始设置任务 ----");

输出如下：

--- 开始设置任务 ----
--- 结束设置任务 ----
开始第 0 项任务
开始第 1 项任务
开始第 2 项任务
完成第 2 项任务
完成第 1 项任务
完成第 0 项任务
全部任务完成