Context，是golang用来控制并发流程的库，它能方便的将主控程序的停止信号传递到goroutinue中，从而实现一键中止关联goroutinue的执行，除此之外，它还能将外部变量通过Value的接口传递到goroutinue中。Context是一个接口类型，可以看下面的代码的定义，可以提供一类代表上下文的值，此类型值是并发安全的，也就是说它可以被传播给多个goroutinue。

// A Context carries a deadline, cancelation signal, and request-scoped values

// across API boundaries. Its methods are safe for simultaneous use by multiple

// goroutines.

type Context interface {

    // Done returns a channel that is closed when this Context is canceled

    // or times out.

    Done() <-chan struct{}

    // Err indicates why this context was canceled, after the Done channel

    // is closed.

    Err() error

    // Deadline returns the time when this Context will be canceled, if any.

    Deadline() (deadline time.Time, ok bool)

    // Value returns the value associated with key or nil if none.

    Value(key interface{}) interface{}

}

如何获得contexts？

context包提供从现有上下文值派生新上下文值的函数。这些值形成一棵树：当上下文被取消时，从它派生的所有上下文也被取消。

这棵树的树根或者说根节点是一个在contex包中预定义好的Context值，它是全局唯一的。通过调用context.Background函数，我们就可以获取到它。

根节点仅仅是一个最基本的支点，不能被撤销，也不携带任何数据

// Background returns an empty Context. It is never canceled, has no deadline,

// and has no values. Background is typically used in main, init, and tests,

// and as the top-level Context for incoming requests.

func Background() Context

可以通过context.Background()获得一个初始Context。生成的context传递给WithCancel，WithDeadline，With Timeout，WithValue来生成不同的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, val interface{}) Context

这四个能衍生context的函数，都接受一个初始Context作为第一个参数。

自己写的例子

package main

import (

  "fmt"

  "context"

  "time"

)

func subPeriodPrint(ctx context.Context, msg string) {

  for {

    stop := false

    select {

      case <-ctx.Done():

        fmt.Printf("Over\n")

        stop = true

      default:

        fmt.Printf("print msg:%s\n", msg)

        time.Sleep(time.Second * 1)

    }

    if stop {

      break

    }

  }

}

func main() {

  // cancel 用来主动发送撤销通知，因为是WithTimeout函数，定时时间到了也会撤销

  ctx, cancel := context.WithTimeout(context.Background(), time.Second * 1)

  for i:=0;i <=1;i++ {

    msg := fmt.Sprintf("current count is %d", i)

    go subPeriodPrint(ctx, msg)

  }

  // 可以设置为5秒和2秒查看打印的不同

  time.Sleep(time.Second * 5)

  fmt.Println("manual cancel")

  cancel()

}

Ctx.WithValue

WithValue可以将参数塞进context里去，可以实现中间件的功能。比如将将用户session和登陆信息在各个requests之间携带。

设置value

ctx := context.WithValue(parentContext, key, value)

获取value

value:=ctx.Value(key)

Go语言实战笔记（二十）| Go Context

Go Concurrency Patterns: Context

Go Concurrency Patterns: Pipelines and cancellation

---恢复内容结束---