怎么实现真正的goroutine超时?

lipengfeihb · · 307 次点击 · 开始浏览    置顶
如下代码,到了超时时间后,main中已经监测到超时了,但是真正处理任务的代码还是在继续执行,这个起不到超时的真正作用,如何能够在超时后停止处理任务handleTask()? ```golang package main import ( "context" "fmt" "time" ) //处理任务 func handleTask(ctx context.Context, ch chan bool, taskId int) { for i := 0; i < 5; i++ { time.Sleep(time.Second) fmt.Println(fmt.Sprintf("处理任务 %d:%d, %v", taskId, i, time.Now())) } ch <- true } func main() { //任务总数 taskNum := 2 //超时时间 timeoutSecond := time.Second * 2 ctx, cancleFun := context.WithTimeout(context.Background(), timeoutSecond) ch := make(chan bool) for i := 1; i <= taskNum; i++ { go handleTask(ctx, ch, i) } allCount := 0 ForControl: for allCount < taskNum { select { case <-ch: allCount++ if allCount == taskNum { break ForControl close(ch) } case <-ctx.Done(): cancleFun() fmt.Println("超时", ctx.Err()) break ForControl } } time.Sleep(timeoutSecond * 2) } ```
307 次点击  
加入收藏 微博
6 回复  |  直到 2018-09-14 09:59:38
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传