濮阳杆衣贸易有限公司

主頁(yè) > 知識(shí)庫(kù) > 解決go在函數(shù)退出后子協(xié)程的退出問(wèn)題

解決go在函數(shù)退出后子協(xié)程的退出問(wèn)題

熱門(mén)標(biāo)簽:excel地圖標(biāo)注分布數(shù)據(jù) 外呼系統(tǒng)用什么卡 百度地圖標(biāo)注后傳給手機(jī) 涿州代理外呼系統(tǒng) 壽光微信地圖標(biāo)注 評(píng)價(jià)高的400電話辦理 電話機(jī)器人軟件免費(fèi) 阿克蘇地圖標(biāo)注 外呼系統(tǒng)顯本地手機(jī)號(hào)

該問(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é)程同步方式

標(biāo)簽:吐魯番 汕頭 蘭州 雞西 銅川 梅河口 重慶 欽州

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《解決go在函數(shù)退出后子協(xié)程的退出問(wèn)題》,本文關(guān)鍵詞  解決,在,函數(shù),退出,后,子,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問(wèn)題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無(wú)關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《解決go在函數(shù)退出后子協(xié)程的退出問(wèn)題》相關(guān)的同類信息!
  • 本頁(yè)收集關(guān)于解決go在函數(shù)退出后子協(xié)程的退出問(wèn)題的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章
    宣化县| 遂平县| 天门市| 金山区| 丹寨县| 盱眙县| 社旗县| 汶上县| 清流县| 津市市| 南充市| 武冈市| 水富县| 衡山县| 西昌市| 汝州市| 望奎县| 大厂| 乾安县| 兴宁市| 商水县| 塔城市| 五大连池市| 平南县| 双峰县| 昭觉县| 尤溪县| 奇台县| 唐山市| 二连浩特市| 五常市| 库伦旗| 张家港市| 连江县| 崇义县| 西峡县| 任丘市| 涟源市| 黑水县| 太谷县| 承德县|