Swift中使用DispatchGroup分组管理异步任务

一、DispatchGroup三种用法:

1.notify(依赖任务)

  let group = DispatchGroup()
        myQueue?.async(group: group, qos: .default, flags: [], execute: { 
            for _ in 0...10 {
               print("耗时任务一")
            }
        })
        myQueue?.async(group: group, qos: .default, flags: [], execute: {
            for _ in 0...10 {
                print("耗时任务二")
            }
        })
        //执行完上面的两个耗时操作, 回到myQueue队列中执行下一步的任务
        group.notify(queue: myQueue!) {
            print("回到该队列中执行")
        }

2.wait(任务等待)

  let group = DispatchGroup()
        myQueue?.async(group: group, qos: .default, flags: [], execute: {
            for _ in 0...10 {
                print("耗时任务一")
            }
        })
        myQueue?.async(group: group, qos: .default, flags: [], execute: {
            for _ in 0...10 {
                print("耗时任务二")
                sleep(UInt32(3))
            }
        })
         //等待上面任务执行,会阻塞当前线程,超时就执行下面的,上面的继续执行。可以无限等待 .distantFuture
        let result = group.wait(timeout: .now() + 2.0)
        switch result {
        case .success:
            print("不超时, 上面的两个任务都执行完")
        case .timedOut:
            print("超时了, 上面的任务还没执行完执行这了")
        }
        
        print("接下来的操作")

3.enter leave 手动管理group计数,enter和leave必须配对

  let group = DispatchGroup()
        group.enter()//把该任务添加到组队列中执行
        myQueue?.async(group: group, qos: .default, flags: [], execute: {
            for _ in 0...10 {
                print("耗时任务一")
                group.leave()//执行完之后从组队列中移除
            }
        })
         group.enter()//把该任务添加到组队列中执行
        myQueue?.async(group: group, qos: .default, flags: [], execute: {
            for _ in 0...10 {
                print("耗时任务二")
                group.leave()//执行完之后从组队列中移除
            }
        })
        
        //当上面所有的任务执行完之后通知
        group.notify(queue: .main) { 
            print("所有的任务执行完了")
        }

二、项目中的实际用例
这次遇到的是一个循环网络请求的功能(怎么老是遇上这种蛋疼的API),要求本地存储的数组里循环取出存储对象,并使用存储对象的属性做参数,POST请求。然后将每次请求下来的数据进行累加计算,最后赋值。上代码:

  func sumTheassets(compHandler:@escaping (_ sum:Float)->()) {
        var asset:Float = 0
        let group = DispatchGroup() //创建group
        for object in objects {  //for循环便利本地存储的数组数据
            group.enter() // 将以下任务添加进group
            let cellViewmodel = MyassetsCellViewModel() // 创建VM对象,并调用网络请求函数
            cellViewmodel.getThepriceFromnew(symbol: object.symbol, compHandler: { (price, ratio) in
                let decimals = Float(object.decimals) // 获取数量,转为Float型
                let num = price * decimals! //计算总价格  单价 * 数量
                asset += num //将计算结果累加
                group.leave() //本次任务完成(即本次for循环任务完成),将任务从group中移除
            })
        }
        group.notify(queue: .main) {  // group中的所有任务完成后再主线程中调用回调函数,将结果传出去
            compHandler(asset)  //在回调里将累加结果传出去
        }
    }

以上,祝大家在开发中都不遇到奇葩API接口或需求 (美好的理想啊)
引用链接:https://www.jianshu.com/p/be5a277e1f96

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,958评论 19 139
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,766评论 18 399
  • 1.解决信号量丢失和假唤醒 public class MyWaitNotify3{ MonitorObject m...
    Q罗阅读 912评论 0 1
  • 梦想与现实之间总是有那么很深的差距,而这也许就是梦想的生活那么令人向往而又受人追捧。想要的生活一直是在脑海中不断浮...
    刘小松阅读 611评论 1 6
  • UIViewController(控制器)的认识 一个控制器负责管理一个大界面 控制器负责界面的创建、事件处理等
    thls阅读 145评论 0 0