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://ybzwz.com/article/gejspi.html