组合 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 项任务
全部任务完成