解決go在函數(shù)退出后子協(xié)程的退出問題
該問題來源于自己在讀fabric源碼時(shí),看到的一個(gè)測試代碼,在一個(gè)函數(shù)中啟用協(xié)程,然后該函數(shù)退出了,由于平常沒有這樣處理過,以及受原有c++函數(shù)域的影響,認(rèn)為函數(shù)退出,子協(xié)程應(yīng)該也退出了呀。
這其實(shí)是自己對go協(xié)程的理解不到位引起的,go的協(xié)程作用域不是在某個(gè)函數(shù)中的,當(dāng)然,如果那個(gè)函數(shù)是main函數(shù),就符合要求了。
該代碼為solo算法的測試代碼:
func goWithWait(target func()) *waitableGo { wg := &waitableGo{ done: make(chan struct{}), } go func() { target()//該協(xié)程會(huì)阻塞在這 close(wg.done)//用來對外通知 }() //外邊結(jié)束,里邊還不結(jié)束嗎? return wg } // This test checks that if consenter is halted before a timer fires, nothing is actually written. func TestHaltBeforeTimeout(t *testing.T) { batchTimeout, _ := time.ParseDuration("1ms") //support的構(gòu)造還不清楚 support := &mockmultichannel.ConsenterSupport{ Blocks: make(chan *cb.Block), BlockCutterVal: mockblockcutter.NewReceiver(), SharedConfigVal: &mockconfig.Orderer{BatchTimeoutVal: batchTimeout}, } defer close(support.BlockCutterVal.Block) bs := newChain(support) //bs.main是solo算法的啟動(dòng)函數(shù),是個(gè)死循環(huán),處理函數(shù) wg := goWithWait(bs.main) defer bs.Halt()//中止 syncQueueMessage(testMessage, bs, support.BlockCutterVal) bs.Halt() select { case <-support.Blocks: t.Fatalf("Expected no invocations of Append") case <-wg.done: } }
遇到該問題后,我寫了幾個(gè)測試:
單純的函數(shù)退出,是不會(huì)影響協(xié)程的
package main import "fmt" var ch chan int func test() int { ch = make(chan int) go func() { for { fmt.Println(<-ch) fmt.Println("hello") } fmt.Println("aaaa") }() //不阻塞,那go func()不會(huì)異常退出嗎? //協(xié)程并不是函數(shù),不會(huì)因?yàn)檫@個(gè)函數(shù)的退出而退出 //test()啟動(dòng)一個(gè)deadloop子協(xié)程,這個(gè)會(huì)在主協(xié)程main結(jié)束后被強(qiáng)制退出 return 0 } func main() { c := test() ch <- 10 fmt.Println("c", c) }
我經(jīng)常在main里邊直接寫協(xié)程的測試demo,main退出會(huì)結(jié)束主協(xié)程,之后會(huì)強(qiáng)制結(jié)束子協(xié)程,一般不會(huì)遇到上述在普通函數(shù)退出的問題,也沒仔細(xì)思考,所以分析源碼時(shí)有點(diǎn)困惑。
子協(xié)程啟動(dòng)子協(xié)程,父協(xié)程的退出,并沒有影響到子協(xié)程
liudeMacBook-Pro:~ liu$ cat tmp.go package main import ( "fmt" "time" ) func test() { go func() { //父協(xié)程 defer func() { fmt.Println("exit dad") }() go func() { //子協(xié)程 defer func() { fmt.Println("exit kid") }() }() }() } func main() { test() time.Sleep(time.Second) } liudeMacBook-Pro:~ liu$ go run tmp.go exit dad exit kid
補(bǔ)充:golang中父子協(xié)程生命周期問題,以及通過context優(yōu)雅關(guān)閉子協(xié)程
背景
上次基于mysql實(shí)現(xiàn)分布式鎖,今天經(jīng)過測試發(fā)現(xiàn)問題,主要是協(xié)程不斷獲取鎖的邏輯存在問題,因?yàn)楂@取鎖的協(xié)程掛掉之后,但其新生成的用來不斷更新鎖的協(xié)程并不會(huì)退出,導(dǎo)致鎖一直不能被釋放,究其原因如下
原因
通過下面代碼即可說明
fmt.Println("main 函數(shù) 開始...") go func() { fmt.Println("父 協(xié)程 開始...") go func() { for { fmt.Println("子 協(xié)程 執(zhí)行中...") timer := time.NewTimer(time.Second * 2) <-timer.C } }() time.Sleep(time.Second*5) fmt.Println("父 協(xié)程 退出...") }() time.Sleep(time.Second*10) fmt.Println("main 函數(shù) 退出")
main 函數(shù) 開始...
父 協(xié)程 開始...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
父 協(xié)程 退出...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
main 函數(shù) 退出
由此可以看出:
main 函數(shù)退出,所有協(xié)程退出
協(xié)程無父子關(guān)系,即在父協(xié)程開啟新的協(xié)程,若父協(xié)程退出,不影響子協(xié)程
解決方式
通過context上下文來解決,當(dāng)然也可以通過channel管道來解決,context解決方式如下:
fmt.Println("main 函數(shù) 開始...") go func() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() fmt.Println("父 協(xié)程 開始...") go func(ctx context.Context) { for { for { select { case <-ctx.Done(): fmt.Println("子 協(xié)程 接受停止信號(hào)...") return default: fmt.Println("子 協(xié)程 執(zhí)行中...") timer := time.NewTimer(time.Second * 2) <-timer.C } } } }(ctx) time.Sleep(time.Second*5) fmt.Println("父 協(xié)程 退出...") }() time.Sleep(time.Second*10) fmt.Println("main 函數(shù) 退出")
main 函數(shù) 開始...
父 協(xié)程 開始...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
父 協(xié)程 退出...
子 協(xié)程 接受停止信號(hào)...
main 函數(shù) 退出
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。
相關(guān)文章
linux中用shell快速安裝配置Go語言的開發(fā)環(huán)境
相信每位開發(fā)者都知道選擇一門開發(fā)語言,免不了需要安裝配置開發(fā)環(huán)境,所以這篇文章給大家分享了linux下使用shell一鍵安裝配置GO語言開發(fā)環(huán)境的方法,有需要的朋友們可以參考借鑒,下面來一起看看吧。2016-10-10Golang當(dāng)中的定時(shí)器實(shí)例詳解
這篇文章主要給大家介紹了關(guān)于Golang當(dāng)中定時(shí)器的相關(guān)資料,定時(shí)器的實(shí)現(xiàn)大家應(yīng)該都遇到過,最近在學(xué)習(xí)golang,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-07-07GoLang日志監(jiān)控系統(tǒng)實(shí)現(xiàn)
這篇文章主要介紹了GoLang日志監(jiān)控系統(tǒng)的實(shí)現(xiàn)流程,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)吧2022-12-12Go語言MySQLCURD數(shù)據(jù)庫操作示例詳解
這篇文章主要為大家介紹了Go語言MySQLCURD數(shù)據(jù)庫操作示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-12-12wind10 idea中 go 開發(fā)環(huán)境搭建教程圖解
這篇文章主要介紹了wind10 idea中 go 開發(fā)環(huán)境搭建過程,本文通過圖文并茂的形式給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-06-06解析golang 標(biāo)準(zhǔn)庫template的代碼生成方法
這個(gè)項(xiàng)目的自動(dòng)生成代碼都是基于 golang 的標(biāo)準(zhǔn)庫 template 的,所以這篇文章也算是對使用 template 庫的一次總結(jié),本文通過實(shí)例代碼給大家介紹的非常詳細(xì),需要的朋友參考下吧2021-11-11