六. GCD队列组

一. 队列组的基本概念

1. 队列组是用来管理队列中任务的执行
2. 一般使用步骤:
   • 创建队列组
   • 创建队列
   • 使用队列组异步函数来封装任务, 然后提交到队列中
   • 把当前所有任务执行的情况, 都纳入到队列组监听的范围中

---

二. 队列组的简单使用: 监听任务的完成

1. 所有的任务会并发的执行(不按序)

2. 所有的异步函数, 都是添加到队列中, 然后再纳入到队列组的监听范围

3. 使用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. 队列组的函数对用法是目前比较少见的用法, 这个用法比较老, 好处是严格的控制/监听了每个进入队列组的任务
2. 该方法只能使用异步函数
3. 基本步骤:

   • 首先要使用队列组创建函数, 创建一个队列组

   • 创建一个并发队列

   • 开启队列组, 然后使用异步函数封装每一个任务

   • 当任务执行结束之后, 要将加入到队列组的任务移除队列组(类似于引用计数管理, 计数+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
        })
    }
}