简介

应用场景

使用

gogetgithub.com/freshcn/async

demo

// 建议程序开启多核支持runtime.GOMAXPROCS(runtime.NumCPU())// 耗时操作1funcrequest1()interface{}{//sql request...}// 耗时操作2funcrequest2()interface{}{//sql request...}// 新建一个async对象async:=async.New()// 添加request1异步请求,第一个参数为该异步请求的唯一logo,第二个参数为异步完成后的回调函数,回调参数类型为func()interface{}async.Add("request1",request1)// 添加request2异步请求async.Add("request2",request2)// 执行ifchans,ok:=async.Run();ok{// 将数据从通道中取回,取回的值是一个map[string]interface{}类型,key为async.Add()时添加的logo,interface{}为该logo回调函数返回的结果res:=<-chans// 这里最好判断下是否所有的异步请求都已经执行成功iflen(res)==2 {fork,v:=rangeres {//do something}}else {log.Println("async not execution all task")}}// 清除掉本次操作的所以数据,方便后续继续使用async对象async.Clean()