Go context
在RPC或者Web服务中,当Server端接受一个request的时候,都会开启一个额外的gorountine来处理内容。有时候可能会使用多个gorountine来处理同一个request。如果对应的request被取消或者timeout,就需要所有为这个request服务的gorountine被快速回收。
context解释更多的是一种上下文
基本方法
-
初始化方法
TODO
Background
-
多种类型的context
WithCancel
WithDeadline
WithTimeout
WithValue
deadline和timeout可以通过使用cancel和timer实现
context接口内容
Deadline:返回deadline,表明对应的context对应的工作需要被cancel。如果返回的ok是false,那么表明就没有设置deadline时间。
-
Done:返回一个channel,当work做完以后这个channel就会被关闭。当对应的context被cancel了就会返回一个chan。
如果done返回是nil表明表明这个context是不能够被cancel的。withcancel,withdeadline,withtimeout都有对应的Done的操作。因为Done会返回一个read chan,可以用于判断对应的context是否被cancel,来控制流程。// func Stream(ctx context.Context, out chan<- Value) error { // for { // v, err := DoSomething(ctx) // if err != nil { // return err // } // select { // case <-ctx.Done(): // return ctx.Err() // case out <- v: // } // } // }
-
Err
如果Done没有被close,那么Err返回的都是nil
如果Done已经执行了close,那么Err返回的是非nil,返回的Error类型可以根据具体的情况判断。就是两种,一种是cancel另一个汇总deadlineExceeded。
-
Value
返回与context的key关联的value
使用方法
context的使用一般都是按照层次性的,这个层次指的是gorountine的层次。因为有可能我们使用多个gorountine或者更深层次的gorountine来处理一个request。
一般使用的根节点都是直接使用context.Background
后边可以与WithCancel,DeadLine,TimeOut配合使用。Parent context可以通过cancel fun等来控制其子context的结束(也对应着子gorountine),并且层层的gorountine需要判断Done。
使用原则
一般context的生存都为一个request,当request结束的时候需要把context销毁。
每次创建一个gorountine,要么将当前的context传递给这个gorountine或者创建一个新的context传递给gorountine。
parent context创建子context的时候,可以获得一个cancel fun,来控制子gorountine的流程。
当子context传递到goroutine应该监控Done对应的channel,如果上层context关闭,就需要做相应的处理。
使用注意
- cancel类型的context在使用的最后一定要调用cancel释放资源,不然有可能Done没有被使用,导致资源无法被释放。或者parent对应的context Done close了。所有在代码中应该尽量及早的cancel对应context
使用模式
-
控制goroutine的生命周期
- 主动cancel一个goroutine,通过withcancel生成对应的child context和cancel,在一定条件下由于父亲goroutine 进行cancel调用
- Timeout 调用(不管对应的child goroutine是否结束都应该调用cancel来释放资源)通常会在defer中使用
- Deadline 调用
不过控制goroutine声明周期的方法还可以使用一个 read chan的方式来实现,但是select并不知道多久会返回,所以可以配置waitgroup
任务或者请求超时,然后中断启的所有子任务的方法
不同的Goroutine携带各自的value变量。