Context
一般被译做 上下文
,通常理解为程序单元的一个运行状态、现场、快照,而翻译中 上下
又很好地诠释了其本质,上下上下则是存在上下层的传递, 上
会把内容传递给 下
。golang
在Go语言中,程序单元也就指的是Goroutine。每一个Goroutine在执行以前,都要先知道程序当前的执行状态,一般将这些执行状态封装在一个Context
变量中,传递给要执行的Goroutine中。上下文则几乎已经成为传递与请求同生存周期变量的标准方法。编程
context
包不只实现了在程序单元之间共享状态变量的方法,同时能经过简单的方法,使咱们在被调用程序单元的外部,经过设置ctx变量值,将过时或撤销这些信号传递给被调用的程序单元。在网络编程中,若存在A调用B的API, B再调用C的API,若A调用B取消,那也要取消B调用C,经过在A,B,C的API调用之间传递 Context
,以及判断其状态,就能解决此问题,这是为何gRPC的接口中带上 ctx context.Context
参数的缘由之一。安全
context
包的核心就是 Context
接口,其定义以下:网络
type Context interface { Deadline() (deadline time.Time, ok bool) Done() <-chan struct{} Err() error Value(key interface{}) interface{} }
Deadline
会返回一个超时时间,Goroutine得到了超时时间后,例如能够对某些io操做设定超时时间。函数
Done
方法返回一个信道(channel),当 Context
被撤销或过时时,该信道是关闭的,即它是一个表示Context是否已关闭的信号。post
当 Done
信道关闭后, Err
方法代表 Contex
t被撤的缘由。ui
Value
可让Goroutine共享一些数据,固然得到数据是协程安全的。但使用这些数据的时候要注意同步,好比返回了一个map,而这个map的读写则要加锁。spa
Context
接口没有提供方法来设置其值和过时时间,也没有提供方法直接将其自身撤销。也就是说, Context
不能改变和撤销其自身。那么该怎么经过 Context
传递改变后的状态呢?.net
不管是Goroutine,他们的建立和调用关系老是像层层调用进行的,就像人的辈分同样,而更靠顶部的Goroutine应有办法主动关闭其下属的Goroutine的执行(否则程序可能就失控了)。为了实现这种关系,Context结构也应该像一棵树,叶子节点须老是由根节点衍生出来的。翻译
要建立Context树,第一步就是要获得根节点, context.Background
函数的返回值就是根节点:
func Background() Context
该函数返回空的Context,该Context通常由接收请求的第一个Goroutine建立,是与进入请求对应的Context根节点,它不能被取消、没有值、也没有过时时间。它经常做为处理Request的顶层context存在。
有了根节点,又该怎么建立其它的子节点,孙节点呢?context包为咱们提供了多个函数来建立他们:
func WithCancel(parent Context) (ctx Context, cancel CancelFunc) func WithDeadline(parent Context, deadline time.Time) (Context, CancelFunc) func WithTimeout(parent Context, timeout time.Duration) (Context, CancelFunc) func WithValue(parent Context, key interface{}, val interface{}) Context
函数都接收一个 Context
类型的参数 parent
,并返回一个 Context
类型的值,这样就层层建立出不一样的节点。子节点是从复制父节点获得的,而且根据接收参数设定子节点的一些状态值,接着就能够将子节点传递给下层的Goroutine了。
再回到以前的问题:该怎么经过 Context
传递改变后的状态呢?使用 Context
的Goroutine没法取消某个操做,其实这也是符合常理的,由于这些Goroutine是被某个父Goroutine建立的,而理应只有父Goroutine能够取消操做。在父Goroutine中能够经过WithCancel方法得到一个cancel方法,从而得到cancel的权利。
第一个 WithCancel
函数,它是将父节点复制到子节点,而且还返回一个额外的 CancelFunc
函数类型变量,该函数类型的定义为:
type CancelFunc func()
调用 CancelFunc
对象将撤销对应的 Context
对象,这就是主动撤销 Context
的方法。在父节点的 Context
所对应的环境中,经过 WithCancel
函数不只可建立子节点的 Context
,同时也得到了该节点 Context
的控制权,一旦执行该函数,则该节点 Context
就结束了,则子节点须要相似以下代码来判断是否已结束,并退出该Goroutine:
select { case <-cxt.Done(): // do some clean... }
WithDeadline
函数的做用也差很少,它返回的Context类型值一样是 parent
的副本,但其过时时间由 deadline
和 parent
的过时时间共同决定。当 parent
的过时时间早于传入的 deadline
时间时,返回的过时时间应与 parent
相同。父节点过时时,其全部的子孙节点必须同时关闭;反之,返回的父节点的过时时间则为 deadline
。
WithTimeout
函数与 WithDeadline
相似,只不过它传入的是从如今开始Context剩余的生命时长。他们都一样也都返回了所建立的子Context的控制权,一个 CancelFunc
类型的函数变量。
当顶层的Request请求函数结束后,咱们就能够cancel掉某个context,从而层层Goroutine根据判断 cxt.Done()
来结束。
WithValue
函数,它返回 parent
的一个副本,调用该副本的Value(key)方法将获得val。这样咱们不光将根节点原有的值保留了,还在子孙节点中加入了新的值,注意若存在Key相同,则会被覆盖。
范例:
package main import ( "fmt" "time" "golang.org/x/net/context" ) func main() { // ctx, cancelFunc := context.WithDeadline(context.Background(), time.Now().Add(time.Second*5)) ctx, cancelFunc := context.WithTimeout(context.Background(), time.Second*5) ctx = context.WithValue(ctx, "Test", "123456") // defer cancelFunc() if t, ok := ctx.Deadline(); ok { fmt.Println(time.Now()) fmt.Println(t.String()) } go func(ctx context.Context) { fmt.Println(ctx.Value("Test")) for { select { case <-ctx.Done(): fmt.Println(ctx.Err()) return // default: // continue } } }(ctx) // if ctx.Err() == nil { // fmt.Println("Sleep 10 seconds...") // time.Sleep(time.Second * 10) // } // if ctx.Err() != nil { // fmt.Println("Alredy exit...") // } time.Sleep(time.Second * 3) cancelFunc() // for { // if ctx.Err() != nil { // fmt.Println("gracefully exit...") // break // } // } }
参考:http://lanlingzi.cn/post/technical/2016/0802_go_context/?utm_source=tuicool&utm_medium=referral
http://blog.csdn.net/u014029783/article/details/53782864
http://blog.csdn.net/zdyueguanyun/article/details/64904703