技术文档

golang学习笔记之-context详细理解篇

2019-01-30  本文已影响173人  Maggie_up
image.png

下面代码演示:

1.context.WithCancel():返回Context和取消函数用来取消Context

package main

import (
    "context"
    "log"
    "os"
    "time"
)

var (
    logg *log.Logger
)

func work(ctx context.Context, ch chan bool) {
    for {
        select {
        case <-ctx.Done():
            logg.Println(`下班!`)
            ch <- true
            return
        default:
            logg.Println(`上班!`)
            time.Sleep(2 * time.Second)
        }
    }
}

func main() {
    ch := make(chan bool)
    logg = log.New(os.Stdout, "", log.Ltime)
    ctx, cancel := context.WithCancel(context.Background())
    go work(ctx, ch)
    time.Sleep(10 * time.Second)
    //取消函数:当cancel被调用时,WithCancel遍历Done以执行关闭;
    cancel()
    // 这个chan是为了保证子的goroutine执行完,当然也可以不用chan用time.Sleep停止几秒
    <-ch
    logg.Println(`无脑发呆中!`)
}
/* outfile:
17:27:52 上班!
17:27:54 上班!
17:27:56 上班!
17:27:58 上班!
17:28:00 上班!
17:28:02 下班!
17:28:02 无脑发呆中!
*/

2.context.WithDeadline()和context.WithTimeout():返回Context和取消函数用来取消Context(这个取消函数会根据设置的时间自动取消)

package main

import (
    "context"
    "log"
    "os"
    "time"
)

var (
    logg *log.Logger
)

func work(ctx context.Context, ch chan bool) {
    for {
        select {
        case <-ctx.Done():
            logg.Println(`下班!`)
            ch <- true
            return
        default:
            logg.Println(`上班!`)
            time.Sleep(2 * time.Second)
        }
    }
}

func main() {
    ch := make(chan bool)
    logg = log.New(os.Stdout, "", log.Ltime)
    ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(5*time.Second))
    go work(ctx, ch)
    time.Sleep(10 * time.Second)
    //取消函数:当cancel被调用时,context.WithDeadline设置的时间超过了,关闭ctx.Done通道。
    cancel()
    // 这个chan是为了保证子的goroutine执行完,当然也可以不用chan用time.Sleep停止几秒
    <-ch
    logg.Println(`无脑发呆中!`)
}
/* outfile:
17:29:43 上班!
17:29:45 上班!
17:29:47 上班!
17:29:49 下班!
17:29:53 无脑发呆中!
*/
3.context.WithTimeout
package main

import (
    "context"
    "log"
    "os"
    "time"
)

var (
    logg *log.Logger
)

func work(ctx context.Context, ch chan bool) {
    for {
        select {
        case <-ctx.Done():
            logg.Println(`下班!`)
            ch <- true
            return
        default:
            logg.Println(`上班!`)
            time.Sleep(2 * time.Second)
        }
    }
}

func main() {
    ch := make(chan bool)
    logg = log.New(os.Stdout, "", log.Ltime)
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    go work(ctx, ch)
    time.Sleep(10 * time.Second)
    //取消函数:当cancel被调用时,context.WithTimeout设置的时间超过后,关闭ctx.Done通道;
    cancel()
    // 这个chan是为了保证子的goroutine执行完,当然也可以不用chan用time.Sleep停止几秒
    <-ch
    logg.Println(`无脑发呆中!`)
}
/*  outfile:
17:34:56 上班!
17:34:58 上班!
17:35:00 上班!
17:35:02 下班!
17:35:06 无脑发呆中!
*/

4.Deadline获取超时时间

package main

import (
    "context"
    "fmt"
    "log"
    "os"
    "time"
)

var (
    logg *log.Logger
)

func work(ctx context.Context, ch chan bool) {
    for {
        /*
        Deadline:是获取设置的超时时间:
        第一个返回值:设置的超时时间,到超时时间Context会自动发起取消请求
        第二个返回值ok==false时表示没有设置截止时间,如果需要取消的话需要调用取消函数进行取消。
        */
        if deadline, ok := ctx.Deadline(); ok {
            fmt.Println(deadline)
            if time.Now().After(deadline) {
                logg.Println(`超时退出!`)
                //这里是为了演示,Context中的Err()输出:context deadline exceeded
                logg.Printf(ctx.Err().Error())
                ch <- true
                return
            }

        }
        select {
        case <-ctx.Done():
            logg.Println(`下班!`)
            ch <- true
            return
        default:
            logg.Println(`上班!`)
            time.Sleep(1 * time.Second)
        }
    }
}

func main() {
    ch := make(chan bool)
    logg = log.New(os.Stdout, "", log.Ltime)
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    go work(ctx, ch)
    time.Sleep(10 * time.Second)
    //取消函数:当cancel被调用时,context.WithTimeout设置的时间超过后,关闭ctx.Done通道;
    cancel()
    // 这个chan是为了保证子的goroutine执行完,当然也可以不用chan用time.Sleep停止几秒
    <-ch
    logg.Println(`无脑发呆中!`)
}
/* outfile:
2019-01-30 18:23:47.851042 +0800 CST m=+5.000360703
18:23:42 上班!
2019-01-30 18:23:47.851042 +0800 CST m=+5.000360703
18:23:43 上班!
2019-01-30 18:23:47.851042 +0800 CST m=+5.000360703
18:23:44 上班!
2019-01-30 18:23:47.851042 +0800 CST m=+5.000360703
18:23:45 上班!
2019-01-30 18:23:47.851042 +0800 CST m=+5.000360703
18:23:46 上班!
2019-01-30 18:23:47.851042 +0800 CST m=+5.000360703
18:23:47 超时退出!
18:23:47 context deadline exceeded //这里就是ctx超时的时候ctx.Err的错误消息。
18:23:52 无脑发呆中!
*/

5.遇到某个上下文在传递的时候:context.WithCancel()存储和检索附加于请求的数据包.当一个函数创建一个goroutine和Context时,它通常会启动一个为请求提供服务的进程,并且子函数可能需要相关的请求信息。

package main

import (
    "context"
    "fmt"
)

func main() {
    ProcessRequest("admin", "admin888")
}

func ProcessRequest(UserName, PassWord string) {
    ctx := context.WithValue(context.Background(), "UserName", UserName)
    ctx = context.WithValue(ctx, "PassWord", PassWord)
    HandleResponse(ctx)
}

func HandleResponse(ctx context.Context) {
    fmt.Printf("处理响应 用户名:%v 密码:%v",
        ctx.Value("UserName"),
        ctx.Value("PassWord"),
    )
}
/* outfile:
处理响应 用户名:admin 密码:admin888
*/

使用的key必须是可比较的,也就是说== 和 != 必须能返回正确的结果
返回值必须是并发安全的,这样才能从多个goroutine访问

type foo int
type bar int

m := make(map[interface{}]int)
m[foo(1)] = 1
m[bar(1)] = 2

fmt.Printf("%v", m)
/*
map[1:2 1:1]
*/

当你把所有这些放在一起时,你会得到类似下面的例子:

package main

import (
    "context"
    "fmt"
)

func main() {
    ProcessRequest("jane", "abc123")
}

type ctxKey int

const (
    ctxUserName ctxKey = iota
    ctxPassWord
)

func UserName(c context.Context) string {
    return c.Value(ctxUserName).(string)
}

func PassWord(c context.Context) string {
    return c.Value(ctxPassWord).(string)
}

func ProcessRequest(UserName, PassWord string) {
    ctx := context.WithValue(context.Background(), ctxUserName, UserName)
    ctx = context.WithValue(ctx, ctxPassWord, PassWord)
    HandleResponse(ctx)
}

func HandleResponse(ctx context.Context) {
    fmt.Printf(
        "处理响应 用户名:%v 密码:%v",
        UserName(ctx),
        PassWord(ctx),
    )
}
/*  outfile:
处理响应 用户名:jane 密码:abc123
*/
上一篇下一篇

猜你喜欢

热点阅读