解決go在函數(shù)退出后子協(xié)程的退出問(wèn)題
該問(wèn)題來(lái)源于自己在讀fabric源碼時(shí),看到的一個(gè)測(cè)試代碼,在一個(gè)函數(shù)中啟用協(xié)程,然后該函數(shù)退出了,由于平常沒(méi)有這樣處理過(guò),以及受原有c++函數(shù)域的影響,認(rèn)為函數(shù)退出,子協(xié)程應(yīng)該也退出了呀。
這其實(shí)是自己對(duì)go協(xié)程的理解不到位引起的,go的協(xié)程作用域不是在某個(gè)函數(shù)中的,當(dāng)然,如果那個(gè)函數(shù)是main函數(shù),就符合要求了。
該代碼為solo算法的測(cè)試代碼:
func goWithWait(target func()) *waitableGo {
wg := &waitableGo{
done: make(chan struct{}),
}
go func() {
target()//該協(xié)程會(huì)阻塞在這
close(wg.done)//用來(lái)對(duì)外通知
}()
//外邊結(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:
}
}
遇到該問(wèn)題后,我寫(xiě)了幾個(gè)測(cè)試:
單純的函數(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ě)協(xié)程的測(cè)試demo,main退出會(huì)結(jié)束主協(xié)程,之后會(huì)強(qiáng)制結(jié)束子協(xié)程,一般不會(huì)遇到上述在普通函數(shù)退出的問(wèn)題,也沒(méi)仔細(xì)思考,所以分析源碼時(shí)有點(diǎn)困惑。
子協(xié)程啟動(dòng)子協(xié)程,父協(xié)程的退出,并沒(méi)有影響到子協(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é)程生命周期問(wèn)題,以及通過(guò)context優(yōu)雅關(guān)閉子協(xié)程
背景
上次基于mysql實(shí)現(xiàn)分布式鎖,今天經(jīng)過(guò)測(cè)試發(fā)現(xiàn)問(wèn)題,主要是協(xié)程不斷獲取鎖的邏輯存在問(wèn)題,因?yàn)楂@取鎖的協(xié)程掛掉之后,但其新生成的用來(lái)不斷更新鎖的協(xié)程并不會(huì)退出,導(dǎo)致鎖一直不能被釋放,究其原因如下
原因
通過(guò)下面代碼即可說(shuō)明
fmt.Println("main 函數(shù) 開(kāi)始...")
go func() {
fmt.Println("父 協(xié)程 開(kāi)始...")
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ù) 開(kāi)始...
父 協(xié)程 開(kāi)始...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
父 協(xié)程 退出...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
main 函數(shù) 退出
由此可以看出:
main 函數(shù)退出,所有協(xié)程退出
協(xié)程無(wú)父子關(guān)系,即在父協(xié)程開(kāi)啟新的協(xié)程,若父協(xié)程退出,不影響子協(xié)程
解決方式
通過(guò)context上下文來(lái)解決,當(dāng)然也可以通過(guò)channel管道來(lái)解決,context解決方式如下:
fmt.Println("main 函數(shù) 開(kāi)始...")
go func() {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
fmt.Println("父 協(xié)程 開(kāi)始...")
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ù) 開(kāi)始...
父 協(xié)程 開(kāi)始...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
子 協(xié)程 執(zhí)行中...
父 協(xié)程 退出...
子 協(xié)程 接受停止信號(hào)...
main 函數(shù) 退出
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。
相關(guān)文章
一步步教你編寫(xiě)可測(cè)試的Go語(yǔ)言代碼
相信每位編程開(kāi)發(fā)者們應(yīng)該都知道,Golang作為一門標(biāo)榜工程化的語(yǔ)言,提供了非常簡(jiǎn)便、實(shí)用的編寫(xiě)單元測(cè)試的能力。本文通過(guò)Golang源碼包中的用法,來(lái)學(xué)習(xí)在實(shí)際項(xiàng)目中如何編寫(xiě)可測(cè)試的Go代碼。有需要的朋友們可以參考借鑒,下面跟著小編一起去學(xué)習(xí)學(xué)習(xí)吧。2016-11-11
go json數(shù)據(jù)轉(zhuǎn)發(fā)的實(shí)現(xiàn)代碼
這篇文章主要介紹了go json數(shù)據(jù)轉(zhuǎn)發(fā)的實(shí)現(xiàn)代碼,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09
golang框架gin的日志處理和zap lumberjack日志使用方式
這篇文章主要介紹了golang框架gin的日志處理和zap lumberjack日志使用方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-01-01
詳解Go語(yǔ)言中Get/Post請(qǐng)求測(cè)試
這篇文章主要為大家詳細(xì)介紹了Go語(yǔ)言中的環(huán)境安裝以及Get和Post請(qǐng)求接口的測(cè)試,文中的示例代碼講解詳細(xì),感興趣的可以跟隨小編一起學(xué)習(xí)一下2022-06-06
詳解如何用Golang處理每分鐘100萬(wàn)個(gè)請(qǐng)求
在項(xiàng)目開(kāi)發(fā)中,我們常常會(huì)遇到處理來(lái)自數(shù)百萬(wàn)個(gè)端點(diǎn)的大量POST請(qǐng)求,本文主要介紹了Golang實(shí)現(xiàn)處理每分鐘100萬(wàn)個(gè)請(qǐng)求的方法,希望對(duì)大家有所幫助2023-04-04

