golang使用context关闭go routine的方法

发布时间:2021-06-21 15:01:27 作者:chen
来源:亿速云 阅读:226

本篇内容主要讲解“golang使用context关闭go routine的方法”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“golang使用context关闭go routine的方法”吧!

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的方法”有了更深的了解,不妨来实际操作一番吧!这里是亿速云网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

推荐阅读:
  1. Go36-32-context.Context
  2. Golang的context包详解

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

golang

上一篇:fastjson中怎么遍历JSONArray

下一篇:Python解析json时提示“string indices must be integers”问题怎么办

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》