Go使用chan或context退出協(xié)程示例詳解
問題
go兩個協(xié)程使用了同一個文件句柄,其中一個協(xié)程關(guān)閉了這個文件句柄并退出了協(xié)程,如何及時通知另一個協(xié)程退出?
分析
當一個協(xié)程關(guān)閉了這個文件對象后,底層文件的文件描述符就會被釋放。
這個時候,另一個協(xié)程還持有著同一個文件對象,但其實對應(yīng)的文件描述符已經(jīng)不存在了。
所以當?shù)诙€協(xié)程通過這個文件對象再對文件進行操作的時候,例如讀寫文件等,就會發(fā)生異常,比如文件描述符不存在錯誤等。
解決
為了避免這個問題,共享文件對象的多個協(xié)程需要通過一個通道或鎖進行協(xié)調(diào):
每個協(xié)程在使用文件對象前需要獲得鎖或從通道接收通知。
最后關(guān)閉文件對象的協(xié)程在關(guān)閉后,通過通道或解鎖來通知其他協(xié)程對象已經(jīng)無效。
其他協(xié)程收到通知后,就不再對這個已關(guān)閉的文件對象進行操作。
1. 使用 channel 通道
在主協(xié)程中,可以定義一個 channel,用來通知其它協(xié)程退出。協(xié)程在執(zhí)行時可以監(jiān)聽這個 channel,一旦接收到退出通知,就可以進行清理工作,并退出協(xié)程。
quit := make(chan bool)
go func() {
defer fmt.Println("Goroutine exit")
for {
select {
case <-quit:
return
default:
// ...
}
}
}()
// 主協(xié)程中發(fā)送退出通知
quit <- true2. 使用 context 包
Go 語言標準庫中提供了 context 包,可以用來控制協(xié)程的生命周期。
在主協(xié)程中可以創(chuàng)建一個 context 對象,并將其傳遞給協(xié)程,然后調(diào)用 cancel 方法,通知所有協(xié)程退出。
context.Background() 是 Go 上下文系統(tǒng)中一個重要的初始預(yù)定義上下文值,代表了一個沒有截止時間限制的空上下文環(huán)境。
1.使用WithCancel函數(shù)創(chuàng)建上下文和取消函數(shù)
ctx, cancel := context.WithCancel(context.Background())
go func(ctx context.Context) {
for {
select {
case <-ctx.Done():
fmt.Println("exit")
return
default:
// 執(zhí)行一些耗時的操作
time.Sleep(1 * time.Second)
fmt.Println("running")
}
}
}(ctx)
time.Sleep(5 * time.Second)
// cancel()
fmt.Println("cancelled")
time.Sleep(1 * time.Second)2.使用Deadline超時結(jié)束協(xié)程
ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(time.Second))
3.使用WithTimeout限定操作時間
ctx, cancel := context.WithTimeout(context.Background(), time.Second)
以上就是Go使用chan或context退出協(xié)程示例詳解的詳細內(nèi)容,更多關(guān)于Go chan context退出協(xié)程的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
golang?slice中常見性能優(yōu)化手段總結(jié)
這篇文章主要為大家詳細一些Golang開發(fā)中常用的slice關(guān)聯(lián)的性能優(yōu)化手段,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學習一下2024-10-10
Go語言基礎(chǔ)switch條件語句基本用法及示例詳解
這篇文章主要為大家介紹了Go語言基礎(chǔ)switch條件語句基本用法及示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步2021-11-11

