Go中context取消goroutine方法

go func(ctx context.Context) {  
    for {  
        select {  
        case <-ctx.Done():  
            fmt.Println("goroutine退出:", ctx.Err())  
            return  
        default:  
            fmt.Println("工作中...")  
            time.Sleep(500 * time.Millisecond)  
        }  
    }  
}(ctx)  

time.Sleep(2 * time.Second)  
cancel() // 触发取消  
time.Sleep(1 * time.Second) // 等待退出  

}

go func() {
timer := time.NewTimer(5 * time.Second)
select {
case <-timer.C:
fmt.Println("任务完成")
case <-ctx.Done():
fmt.Println("任务被取消:", ctx.Err())
if !timer.Stop() {
<-timer.C // 防止泄漏
}
}
}()

go func() {  
    for {  
        select {  
        case <-childCtx.Done():  
            fmt.Println("子goroutine退出")  
            return  
        default:  
            time.Sleep(300 * time.Millisecond)  
        }  
    }  
}()  

// 模拟工作  
time.Sleep(2 * time.Second)  

}(ctx)

只要任意一个case触发就会跳出循环，其中ctx.Done()优先级最高。

基本上就这些。掌握context取消的核心在于：传递context、监听Done channel、及时调用cancel。只要遵循这些原则，就能写出可控制的并发程序。

今天关于《Go中context取消goroutine方法》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！