完 golang开发:go并发的建议 _生活百科

上次说了一下Go语言布道师 Dave Cheney对Go并发的建议，个人觉得最重要的一条，这次主要想说一下这个。8.3. Never start a goroutine without knowning when it will stop(永远不要在不知道何时停止的情况下启动 goroutine)

我们的需求我这边当时有个需求是这样的，我们有个考试系统的，每次学员答完试卷去检查一下这次交卷是否是这次考试的最后一份试卷，如果是最后一份试卷的话，需要计算这次考试的总成绩，生成考试的学习报告，当然了，如果不是最后一份试卷的话啥也不干。生成试卷和报告是必须要生成的，不能出现考完试了没有总成绩和总报告。接到这个需求的时候，我首先想到的是使用golang的goroutine去异步算出成绩生成报告。然后写代码就是这样的。
go createReport()这不刚好是8.3 永远不要这样写的建议么？然后觉得应该写一个管理goroutine异步执行任务的类库，创建执行销毁都由这个管理工具去执行。准备写的时候发现B站的代码里有一个这样的类库，异步执行的类库。
B站的类库B站代码里面异步任务是这个文件openbilibili-go-common-master/library/sync/pipeline/fanout/fanout.go
var ( // ErrFull chan full. ErrFull = errors.New("fanout: chan full") stats = prom.BusinessInfoCount traceTags = []trace.Tag{trace.Tag{Key: trace.TagSpanKind, Value: "background"},trace.Tag{Key: trace.TagComponent, Value: "sync/pipeline/fanout"}, })type options struct { worker int buffer int}// Option fanout optiontype Option func(*options)// Worker specifies the worker of fanoutfunc Worker(n int) Option { if n <= 0 {panic("fanout: worker should > 0") } return func(o *options) {o.worker = n }}// Buffer specifies the buffer of fanoutfunc Buffer(n int) Option { if n <= 0 {panic("fanout: buffer should > 0") } return func(o *options) {o.buffer = n }}type item struct { f func(c context.Context) ctx context.Context}// Fanout async consume data from chan.type Fanout struct { name string ch chan item options *options waiter sync.WaitGroup ctx context.Context cancel func()}// New new a fanout struct.func New(name string, opts ...Option) *Fanout { if name == "" {name = "fanout" } o := &options{worker: 1,buffer: 1024, } for _, op := range opts {op(o) } c := &Fanout{ch: make(chan item, o.buffer),name: name,options: o, } c.ctx, c.cancel = context.WithCancel(context.Background()) c.waiter.Add(o.worker) for i := 0; i < o.worker; i++ {go c.proc() } return c}func (c *Fanout) proc() { defer c.waiter.Done() for {select {case t := <-c.ch:wrapFunc(t.f)(t.ctx)stats.State(c.name+"_channel", int64(len(c.ch)))case <-c.ctx.Done():return} }}func wrapFunc(f func(c context.Context)) (res func(context.Context)) { res = func(ctx context.Context) {defer func() {if r := recover(); r != nil {buf := make([]byte, 64*1024)buf = buf[:runtime.Stack(buf, false)]log.Error("panic in fanout proc, err: %s, stack: %s", r, buf)}}()f(ctx)if tr, ok := trace.FromContext(ctx); ok {tr.Finish(nil)} } return}// Do save a callback func.func (c *Fanout) Do(ctx context.Context, f func(ctx context.Context)) (err error) { if f == nil || c.ctx.Err() != nil {return c.ctx.Err() } nakeCtx := metadata.WithContext(ctx) if tr, ok := trace.FromContext(ctx); ok {tr = tr.Fork("", "Fanout:Do").SetTag(traceTags...)nakeCtx = trace.NewContext(nakeCtx, tr) } select { case c.ch <- item{f: f, ctx: nakeCtx}: default:err = ErrFull } stats.State(c.name+"_channel", int64(len(c.ch))) return}// Close close fanoutfunc (c *Fanout) Close() error { if err := c.ctx.Err(); err != nil {return err } c.cancel() c.waiter.Wait() return nil}使用方法 ca := New("cache", Worker(100), Buffer(1024)) var run bool ca.Do(context.Background(), func(c context.Context) {run = true })

完 golang开发:go并发的建议

推荐阅读

母亲节要买什么礼物,分享几款走心的

2022年护士年终工作总结 2022美工个人年终工作总结

双子座的床上功夫

金鱼眼面相解析，有金鱼眼的人运势怎么样

怎么去胶？

抗皱六胜肽精华液的使用方法六胜肽抗皱精华液使用方法

手机无响应的解决方法应该怎么解决呢

白煮牛肉的家常做法大全白煮牛肉的家常做法

宝马有什么技术

形容经历了事情的成语是什么

糖不甩怎么做才Q

猫咪渴了的表现

瘦麒麟臂方法瘦胳膊最有效的方法

开元通宝680万图片 &#8211; 开元通宝2020价格

汽车贴膜前需要洗车吗汽车贴膜前要洗车吗?

关于本玉12号简述本玉12号

蓝牙耳机使用小技巧蓝牙耳机的正确使用方法

诗歌鉴赏蜀相咏史怀古诗蜀相的作者

梦见下牙掉了,但没流血是什么意思

越狱第3季中第几集越狱成功？