Go使用chan或context退出協(xié)程示例詳解
問題
go兩個(gè)協(xié)程使用了同一個(gè)文件句柄，其中一個(gè)協(xié)程關(guān)閉了這個(gè)文件句柄并退出了協(xié)程，如何及時(shí)通知另一個(gè)協(xié)程退出？
分析
當(dāng)一個(gè)協(xié)程關(guān)閉了這個(gè)文件對象后，底層文件的文件描述符就會被釋放。
這個(gè)時(shí)候，另一個(gè)協(xié)程還持有著同一個(gè)文件對象，但其實(shí)對應(yīng)的文件描述符已經(jīng)不存在了。
所以當(dāng)?shù)诙€(gè)協(xié)程通過這個(gè)文件對象再對文件進(jìn)行操作的時(shí)候，例如讀寫文件等，就會發(fā)生異常，比如文件描述符不存在錯(cuò)誤等。
解決
為了避免這個(gè)問題，共享文件對象的多個(gè)協(xié)程需要通過一個(gè)通道或鎖進(jìn)行協(xié)調(diào):
每個(gè)協(xié)程在使用文件對象前需要獲得鎖或從通道接收通知。
最后關(guān)閉文件對象的協(xié)程在關(guān)閉后，通過通道或解鎖來通知其他協(xié)程對象已經(jīng)無效。
其他協(xié)程收到通知后，就不再對這個(gè)已關(guān)閉的文件對象進(jìn)行操作。
1. 使用 channel 通道
在主協(xié)程中，可以定義一個(gè) channel，用來通知其它協(xié)程退出。協(xié)程在執(zhí)行時(shí)可以監(jiān)聽這個(gè) channel，一旦接收到退出通知，就可以進(jìn)行清理工作，并退出協(xié)程。
quit := make(chan bool)
go func() {
defer fmt.Println("Goroutine exit")
for {
select {
case <-quit:
return
default:
// ...
}
}
}()
// 主協(xié)程中發(fā)送退出通知
quit <- true2. 使用 context 包
Go 語言標(biāo)準(zhǔn)庫中提供了 context 包，可以用來控制協(xié)程的生命周期。
在主協(xié)程中可以創(chuàng)建一個(gè) context 對象，并將其傳遞給協(xié)程，然后調(diào)用 cancel 方法，通知所有協(xié)程退出。
context.Background() 是 Go 上下文系統(tǒng)中一個(gè)重要的初始預(yù)定義上下文值，代表了一個(gè)沒有截止時(shí)間限制的空上下文環(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í)行一些耗時(shí)的操作
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超時(shí)結(jié)束協(xié)程
ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(time.Second))
3.使用WithTimeout限定操作時(shí)間
ctx, cancel := context.WithTimeout(context.Background(), time.Second)
以上就是Go使用chan或context退出協(xié)程示例詳解的詳細(xì)內(nèi)容，更多關(guān)于Go chan context退出協(xié)程的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了使用Gomock進(jìn)行單元測試的方法示例，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-11-11
Go語言中獲取函數(shù)實(shí)體的四種方法小結(jié)
本文主要介紹了Go語言中獲取函數(shù)實(shí)體的四種方法,包括反射獲取地址、runtime獲取名稱、函數(shù)變量傳遞實(shí)體及包內(nèi)函數(shù)解析,具有一定的參考價(jià)值,感興趣的可以了解一下2025-05-05
Golang實(shí)現(xiàn)按比例切分流量的示例詳解
我們在進(jìn)行灰度發(fā)布時(shí),往往需要轉(zhuǎn)發(fā)一部分流量到新上線的服務(wù)上,進(jìn)行小規(guī)模的驗(yàn)證,隨著功能的不斷完善,我們也會逐漸增加轉(zhuǎn)發(fā)的流量,這就需要按比例去切分流量,那么如何實(shí)現(xiàn)流量切分呢,接下來小編就給大家詳細(xì)的介紹一下實(shí)現(xiàn)方法,需要的朋友可以參考下2023-09-09
golang?slice中常見性能優(yōu)化手段總結(jié)
這篇文章主要為大家詳細(xì)一些Golang開發(fā)中常用的slice關(guān)聯(lián)的性能優(yōu)化手段,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-10-10
golang使用信號量熱更新的實(shí)現(xiàn)示例
這篇文章主要介紹了golang使用信號量熱更新的實(shí)現(xiàn)示例，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-04-04
這篇文章主要介紹了一文詳解Golang中的切片數(shù)據(jù)類型，切片是一個(gè)種特殊的數(shù)組。是對數(shù)組的一個(gè)連續(xù)片段的引用，所以切片是一個(gè)引用類型2022-09-09
本文主要介紹了Golang?分割字符串的實(shí)現(xiàn)示例,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
Go反射reflect包提供類型和值方法,用于獲取類型信息、訪問字段、調(diào)用方法等,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2025-07-07
這篇文章主要為大家介紹了go?mod文件內(nèi)容版本號簡單用法詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-10-10
Go語言基礎(chǔ)switch條件語句基本用法及示例詳解
這篇文章主要為大家介紹了Go語言基礎(chǔ)switch條件語句基本用法及示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步2021-11-11