Go使用chan或context退出協(xié)程示例詳解
問題
go兩個協(xié)程使用了同一個文件句柄，其中一個協(xié)程關(guān)閉了這個文件句柄并退出了協(xié)程，如何及時通知另一個協(xié)程退出？
分析
當(dāng)一個協(xié)程關(guān)閉了這個文件對象后，底層文件的文件描述符就會被釋放。
這個時候，另一個協(xié)程還持有著同一個文件對象，但其實對應(yīng)的文件描述符已經(jīng)不存在了。
所以當(dā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)文章
這篇文章主要為大家詳細介紹了Go語言中獲取IP地址的相關(guān)方法,文中的示例代碼講解詳細,具有一定的學(xué)習(xí)價值,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-11-11
在?Golang?中使用?Cobra?創(chuàng)建?CLI?應(yīng)用
這篇文章主要介紹了在?Golang?中使用?Cobra?創(chuàng)建?CLI?應(yīng)用,來看下?Cobra?的使用，這里我們使用的?go1.13.3?版本，使用?Go?Modules?來進行包管理,需要的朋友可以參考下2022-01-01
這篇文章主要為大家介紹了go kratos源碼及配置解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-12-12
go使用errors.Wrapf()代替log.Error()方法示例
這篇文章主要為大家介紹了go使用errors.Wrapf()代替log.Error()的方法示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-08-08
這篇文章主要介紹了Go語言單鏈表實現(xiàn)方法,實例分析了基于Go語言的單鏈表實現(xiàn)原理與使用技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-03-03
在 Go 語言中,我們常用的數(shù)據(jù)結(jié)構(gòu)有在Go語言中,你可以初始化不同的數(shù)據(jù)結(jié)構(gòu),例如數(shù)組、切片、結(jié)構(gòu)體、指針、map等,本文將給大家介紹一下Golang變量直接初始化的方法,需要的朋友可以參考下2023-08-08
zap是一個可以在go項目中進行快速,?結(jié)構(gòu)化且分級的日志記錄包,?git?star數(shù)高達16.3k,?Git?項目地址,?在各大公司項目中被廣泛使用，這篇文章主要介紹了GO語言框架中如何快速集成日志模塊,需要的朋友可以參考下2022-07-07
Go語言并發(fā)編程之互斥鎖Mutex和讀寫鎖RWMutex
Go 語言中提供了很多同步工具，本文將介紹互斥鎖Mutex和讀寫鎖RWMutex的使用方法，想要具體了解的小伙伴，請參考下面文章詳細內(nèi)容，希望對你有所幫助2021-10-10
重學(xué)Go語言之如何開發(fā)RPC應(yīng)用
這篇文章主要為大家詳細介紹了在Go語言中如何構(gòu)建RPC應(yīng)用,文中的示例代碼講解詳細,具有一定的學(xué)習(xí)價值,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-09-09
簡潔的代碼對于創(chuàng)建可維護、可閱讀和高效的軟件至關(guān)重要,Go 是一種強調(diào)簡單和代碼整潔的語言,在本文中,我們將結(jié)合代碼示例,探討編寫簡潔 Go 代碼的最佳實踐,需要的朋友可以參考下2023-09-09