該問(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ò)誤或未考慮完全的地方,望不吝賜教。
您可能感興趣的文章:- Go 并發(fā)實(shí)現(xiàn)協(xié)程同步的多種解決方法
- go等待一組協(xié)程結(jié)束的操作方式
- golang協(xié)程池模擬實(shí)現(xiàn)群發(fā)郵件功能
- Go使用協(xié)程交替打印字符
- Golang 之協(xié)程的用法講解
- go 協(xié)程返回值處理操作
- 淺談golang for 循環(huán)中使用協(xié)程的問(wèn)題
- Go并發(fā):使用sync.WaitGroup實(shí)現(xiàn)協(xié)程同步方式