golang使用context关闭goroutine的方法
本篇内容主要讲解“golang使用context关闭go routine的方法”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“golang使用context关闭go routine的方法”吧!
成都创新互联公司主营锡林郭勒盟网站建设的网络公司,主营网站建设方案,成都APP应用开发,锡林郭勒盟h5重庆小程序开发搭建,锡林郭勒盟网站营销推广欢迎锡林郭勒盟等地区企业咨询
go中的context
go语言提供了context包,支持在多个go routine之间传递信号,可以使用它优雅的取消任务,从而优雅的结束go routine,节约系统资源。
实践
今天遇到了这个任务,有多科考试,需要比对一下各个学科的考试学生名单是否一致,考虑到假如有好几科,然后每科有几千个学生,如果只用循环那么需要循环几万次,于是就开了协程结合context进行处理。话不多说,直接上代码:
var baseStus []examstudent.StudentViewModel linq.From(stuMap[int(sexams[0].SeID)]).OrderBy(func(i interface{}) interface{} { return i.(examstudent.StudentViewModel).ExamCode }).ToSlice(&baseStus) //定义一个支持取消的context ctx, cancel := context.WithCancel(context.Background()) //标志,用来区分是一致还是不一致 sch := make(chan int, len(sexams)-1) for i, _ := range sexams { if i == 0 { continue } //开启协程 go func(c context.Context, index int) { var compareStus []examstudent.StudentViewModel linq.From(stuMap[int(sexams[i].SeID)]).OrderBy(func(x interface{}) interface{} { return x.(examstudent.StudentViewModel).ExamCode }).ToSlice(&compareStus) for x, vv := range baseStus { select { case <-c.Done(): return default: if vv.ExamCode != compareStus[x].ExamCode { cancel() //如果不一致就取消任务 return } } } sch <- index }(ctx, i) } defer cancel() defer close(sch) for { select {//select语句 case <-ctx.Done(): return false, nil //执行了这个地方就表示不一致了 case <-sch: if len(sch) == 0 { return true, nil } } }
到此,相信大家对“golang使用context关闭go routine的方法”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
网站标题:golang使用context关闭goroutine的方法
浏览路径:http://azwzsj.com/article/gejspi.html