分享
golang context.WithTimeout 超时处理
ylqmf · · 10082 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
<span style="font-size:18px;color:#3333ff;">package main
import (
"golang.org/x/net/context"
"log"
"math/rand"
"time"
)
func test(is_first *bool, prev_map *map[string]string) {
rand.Seed(int64(time.Now().Nanosecond()))
ch := make(chan bool)
ctx, _ := context.WithTimeout(context.Background(), 50*time.Millisecond)
go func() {
if *is_first {
(*prev_map)["a"] = "1"
} else {
(*prev_map)["a"] = "2"
}
time.Sleep(time.Duration(rand.Intn(100)) * time.Millisecond)
ch <- true
}()
select {
case <-ch:
*is_first = false
(*prev_map)["b"] = "fast"
return
case <-ctx.Done():
*is_first = true
(*prev_map)["b"] = "slow"
return
}
}
func main() {
is_first := true
prev_map := make(map[string]string)
for {
test(&is_first, &prev_map)
time.Sleep(time.Second)
log.Println(prev_map, is_first)
}
}</span>
<span style="font-size:18px;color:#3333ff;">[work@localhost test]$ go run main.go 2016年08月18日 23:22:26 map[a:1 b:fast] false 2016年08月18日 23:22:27 map[a:2 b:slow] true 2016年08月18日 23:22:28 map[a:1 b:slow] true 2016年08月18日 23:22:29 map[a:1 b:fast] false 2016年08月18日 23:22:30 map[b:fast a:2] false 2016年08月18日 23:22:31 map[b:slow a:2] true 2016年08月18日 23:22:32 map[a:1 b:fast] false 2016年08月18日 23:22:33 map[a:2 b:slow] true 2016年08月18日 23:22:34 map[a:1 b:slow] true 2016年08月18日 23:22:35 map[a:1 b:slow] true 2016年08月18日 23:22:36 map[a:1 b:slow] true ^Csignal: interrupt</span>
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信10082 次点击
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
<span style="font-size:18px;color:#3333ff;">package main
import (
"golang.org/x/net/context"
"log"
"math/rand"
"time"
)
func test(is_first *bool, prev_map *map[string]string) {
rand.Seed(int64(time.Now().Nanosecond()))
ch := make(chan bool)
ctx, _ := context.WithTimeout(context.Background(), 50*time.Millisecond)
go func() {
if *is_first {
(*prev_map)["a"] = "1"
} else {
(*prev_map)["a"] = "2"
}
time.Sleep(time.Duration(rand.Intn(100)) * time.Millisecond)
ch <- true
}()
select {
case <-ch:
*is_first = false
(*prev_map)["b"] = "fast"
return
case <-ctx.Done():
*is_first = true
(*prev_map)["b"] = "slow"
return
}
}
func main() {
is_first := true
prev_map := make(map[string]string)
for {
test(&is_first, &prev_map)
time.Sleep(time.Second)
log.Println(prev_map, is_first)
}
}</span>
<span style="font-size:18px;color:#3333ff;">[work@localhost test]$ go run main.go 2016年08月18日 23:22:26 map[a:1 b:fast] false 2016年08月18日 23:22:27 map[a:2 b:slow] true 2016年08月18日 23:22:28 map[a:1 b:slow] true 2016年08月18日 23:22:29 map[a:1 b:fast] false 2016年08月18日 23:22:30 map[b:fast a:2] false 2016年08月18日 23:22:31 map[b:slow a:2] true 2016年08月18日 23:22:32 map[a:1 b:fast] false 2016年08月18日 23:22:33 map[a:2 b:slow] true 2016年08月18日 23:22:34 map[a:1 b:slow] true 2016年08月18日 23:22:35 map[a:1 b:slow] true 2016年08月18日 23:22:36 map[a:1 b:slow] true ^Csignal: interrupt</span>