一. 队列组的基本概念
- 队列组是用来管理队列中任务的执行
- 一般使用步骤:
- 创建队列组
- 创建队列
- 使用队列组异步函数来封装任务, 然后提交到队列中
- 把当前所有任务执行的情况, 都纳入到队列组监听的范围中
二. 队列组的简单使用: 监听任务的完成
所有的任务会并发的执行(不按序)
所有的异步函数, 都是添加到队列中, 然后再纳入到队列组的监听范围
-
使用
dispatch_group_notify(队列组, 队列)函数, 来监听在这个函数上面的任务执行是否完成, 当任务完成, 就会调用这个方法// 1. 创建队列组 dispatch_group_t group = dispatch_group_create(); // 2. 创建并发队列 dispatch_queue_t queue = dispatch_queue_create("123", DISPATCH_QUEUE_CONCURRENT); // 3. 使用函数添加任务 dispatch_group_async(group, queue, ^{ NSLog(@"1---%@", [NSThread currentThread]); }); dispatch_group_async(group, queue, ^{ NSLog(@"2---%@", [NSThread currentThread]); }); dispatch_group_async(group, queue, ^{ NSLog(@"3---%@", [NSThread currentThread]); }); dispatch_group_async(group, queue, ^{ NSLog(@"4---%@", [NSThread currentThread]); }); // 4. 让队列组监听任务的完成 dispatch_group_notify(group, queue, ^{ NSLog(@"执行完毕"); });
三.队列组和函数对
- 队列组的函数对用法是目前比较少见的用法, 这个用法比较老, 好处是严格的控制/监听了每个进入队列组的任务
- 该方法只能使用异步函数
- 基本步骤:
首先要使用队列组创建函数, 创建一个队列组
创建一个并发队列
开启队列组, 然后使用异步函数封装每一个任务
-
当任务执行结束之后, 要将加入到队列组的任务移除队列组(类似于引用计数管理, 计数+1必须伴随计数-1) + 队列组通常与dispatch_group_wait连用, 等待队列组中的任务X秒, 之后再继续执行后面的任务
- (void)groupQueue2 { // 1. 获取队列组 dispatch_group_t group = dispatch_group_create(); // 2. 创建队列 dispatch_queue_t queue = dispatch_get_global_queue(0, 0); // 3. 队列组开启 -- 将下面的任务纳入队列组中 dispatch_group_enter(group); // 4. 使用异步函数封装任务 dispatch_async(queue, ^{ NSLog(@"1---%@", [NSThread currentThread]); // 5. 确保任务结束之后，让该任务离开队列组 dispatch_group_leave(group); }); dispatch_group_enter(group); dispatch_async(queue, ^{ NSLog(@"2---%@", [NSThread currentThread]); dispatch_group_leave(group); }); dispatch_group_enter(group); dispatch_async(queue, ^{ NSLog(@"3---%@", [NSThread currentThread]); dispatch_group_leave(group); }); // // 拦截通知 // dispatch_group_notify(group, queue, ^{ // NSLog(@"任务结束"); // }); // 同步执行，等待队列组time的时间后执行后面的代码，如果队列组中的任务都完成了，就返回0，如果没完成，就返回非0值 dispatch_time_t timer = dispatch_time(DISPATCH_TIME_NOW, 0.00000002 * NSEC_PER_SEC); // 等待tiemr秒的时间，不管队列中任务是否完成，都继续往下执行，如果改时间内任务完成了就返回0，否则是非零值 long n = dispatch_group_wait(group, timer); NSLog(@"%ld", n); NSLog(@"----end------"); }
四. 使用队列组的小实例 --- 下载两张图片, 然后合成后展示
override func touchesBegan(touches: Set<UITouch>, withEvent event: UIEvent?) {
// 1. 创建队列组
let group = dispatch_group_create()
// 2. 创建并发队列
let queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_HIGH, 0)
// 3. 异步下载图片1
dispatch_group_async(group, queue) { () -> Void in
// 获取URL
guard let url = NSURL(string: "http://wanzao2.b0.upaiyun.com/system/pictures/33164301/original/1455500488_500x500.png") else {
return
}
// 获取URL的二进制数据
guard let data = NSData(contentsOfURL: url) else {return};
// 从URL获取图片
let image = UIImage(data: data)
self.image1 = image
debugPrint(NSThread.currentThread())
}
// 4. 异步下载图片2
dispatch_group_async(group, queue) { () -> Void in
guard let url = NSURL(string: "http://ww1.sinaimg.cn/large/e389bb44jw1efrld60zctj20cs0bdglv.jpg") else {return}
guard let data = NSData(contentsOfURL: url) else {return}
let image = UIImage(data: data)
self.image2 = image
debugPrint(NSThread.currentThread())
}
// 如果这时直接合成图片的话, 有可能因为图片未下载完成, 导致合成失败
/*
// 5.1 使用栅栏函数, 等上面的函数结束之后, 再调用下面的方法, 注意图片合成要回主线程
dispatch_barrier_async(queue) { () -> Void in
debugPrint("barrier--------")
}
// 5.2 等栅栏过去之后, 再绘制并且刷新UI界面
dispatch_group_async(group, queue) { () -> Void in
UIGraphicsBeginImageContext(CGSizeMake(200, 200))
self.image1?.drawInRect(CGRectMake(0, 0, 200, 100))
self.image2?.drawInRect(CGRectMake(0, 100, 200, 100))
let image = UIGraphicsGetImageFromCurrentImageContext()
// 回到主线程设置UI
dispatch_async(dispatch_get_main_queue(), { () -> Void in
self.imageView.image = image
})
}
*/
// 6.1 除了栅栏函数, 还可以使用队列组的拦截监听, 当队列组中的任务都执行完毕的时候, 就会调用拦截函数中的回调
// 该方法相对栅栏函数节省一点步骤, 也更符合队列组的使用方法
dispatch_group_notify(group, queue) { () -> Void in
UIGraphicsBeginImageContext(CGSizeMake(200, 200))
self.image1?.drawInRect(CGRectMake(0, 0, 200, 100))
self.image2?.drawInRect(CGRectMake(0, 100, 200, 100))
let image = UIGraphicsGetImageFromCurrentImageContext()
// 回到主线程设置UI
dispatch_async(dispatch_get_main_queue(), { () -> Void in
self.imageView.image = image
})
}
}