经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » Go语言 » 查看文章
GOLANG使用Context实现传值、超时和取消的方法
来源:jb51  时间:2019/1/15 9:19:18  对本文有异议

GO1.7之后,新增了context.Context这个package,实现goroutine的管理。

Context基本的用法参考GOLANG使用Context管理关联goroutine

实际上,Context还有个非常重要的作用,就是设置超时。比如,如果我们有个API是这样设计的:

  1. type Packet interface {
  2. encoding.BinaryMarshaler
  3. encoding.BinaryUnmarshaler
  4. }
  5.  
  6. type Stack struct {
  7. }
  8. func (v *Stack) Read(ctx context.Context) (pkt Packet, err error) {
  9. return
  10. }
  11.  

一般使用是这样使用,创建context然后调用接口:

  1. ctx,cancel := context.WithCancel(context.Background())
  2. stack := &Stack{}
  3. pkt,err := stack.Read(ctx)

那么,它本身就可以支持取消和超时,也就是用户如果需要取消,比如发送了SIGINT信号,程序需要退出,可以在收到信号后调用cancel:

  1. sc := make(chan os.Signal, 0)
  2. signal.Notify(sc, syscall.SIGINT, syscall.SIGTERM)
  3. go func() {
  4. for range sc {
  5. cancel()
  6. }
  7. }()

如果需要超时,这个API也不用改,只需要调用前设置超时时间:

  1. ctx,cancel := context.WithTimeout(context.Background(), 3*time.Second)
  2. defer cancel()
  3. pkt,err := stack.Read(ctx)

如果一个程序在运行,比如Read在等待,那么在没有人工干预的情况下,那就应该自己运行就好了。而人工干预,也就是需要取消,比如要升级程序了,或者需要停止服务了,都属于这种取消操作。而超时,一般是系统的策略,因为不能一直等下去,就需要在一定时间没有反应时终止服务。实际上context这两个都能支持得很好,而且还不影响Read本身的逻辑,在Read中只需要关注context是否Done:

  1. func (v *Stack) Read(ctx context.Context) (pkt Packet, err error) {
  2. select {
  3. // case <- dataChannel: // Parse packet from data channel.
  4. case <- ctx.Done():
  5. return nil,ctx.Err()
  6. }
  7. return
  8. }

这是为何context被接纳成为标准库的包的缘故了吧,非常之强大和好用,而又非常简单。一行context,深藏功与名。

另外,Context还可以传递上下文的Key-Value对象,比如我们希望日志中,相关的goroutine都打印一个简化的CID,那么就可以用context.WithValue,参考go-oryx-lib/logger。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持w3xue。

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号