最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

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

 更新時(shí)間:2021年04月30日 15:50:48   作者:longtails  
這篇文章主要介紹了解決go在函數(shù)退出后子協(xié)程的退出問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

該問(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)文章

  • go處理線程之間的交互示例代碼

    go處理線程之間的交互示例代碼

    Go語(yǔ)言以goroutine為核心實(shí)現(xiàn)并發(fā)編程,其中線程間交互主要通過(guò)Channels、WaitGroup、Mutex和Select實(shí)現(xiàn),Channels提供goroutine間的數(shù)據(jù)傳遞,本文給大家介紹go處理線程之間的交互示例代碼,感興趣的朋友一起看看吧
    2024-10-10
  • Golang單元測(cè)試中的技巧分享

    Golang單元測(cè)試中的技巧分享

    這篇文章主要為大家詳細(xì)介紹了Golang進(jìn)行單元測(cè)試時(shí)的一些技巧和科技,文中的示例代碼講解詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴可以了解一下
    2023-03-03
  • 解讀golang中的const常量和iota

    解讀golang中的const常量和iota

    這篇文章主要介紹了golang中的const常量和iota,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-12-12
  • 重學(xué)Go語(yǔ)言之如何使用Redis

    重學(xué)Go語(yǔ)言之如何使用Redis

    Redis是我們開(kāi)發(fā)應(yīng)用程序中很常用的NoSQL數(shù)據(jù)庫(kù),那么在Go語(yǔ)言中要如何連接和操作Redis呢,在這篇文章中,我們就來(lái)一起來(lái)探究一下吧
    2023-08-08
  • 一步步教你編寫(xiě)可測(cè)試的Go語(yǔ)言代碼

    一步步教你編寫(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語(yǔ)言中的逃逸分析

    淺析Go語(yǔ)言中的逃逸分析

    在Go語(yǔ)言中,內(nèi)存分配和逃逸分析是至關(guān)重要的概念,對(duì)于理解代碼的性能和內(nèi)存使用情況至關(guān)重要,本文將深入探討Go語(yǔ)言中的內(nèi)存分配原理以及逃逸分析的作用,希望對(duì)大家有所幫助
    2024-04-04
  • go json數(shù)據(jù)轉(zhuǎn)發(fā)的實(shí)現(xiàn)代碼

    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日志使用方式

    這篇文章主要介紹了golang框架gin的日志處理和zap lumberjack日志使用方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-01-01
  • 詳解Go語(yǔ)言中Get/Post請(qǐng)求測(cè)試

    詳解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)求

    詳解如何用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

最新評(píng)論

凯里市| 利辛县| 梁平县| 霍州市| 龙川县| 安西县| 油尖旺区| 湘潭市| 连州市| 河南省| 潮州市| 多伦县| 日土县| 襄城县| 桦甸市| 昌乐县| 嘉黎县| 伊吾县| 宁夏| 日照市| 贵定县| 东港市| 台中县| 松原市| 松桃| 望谟县| 浏阳市| 金阳县| 唐河县| 台州市| 游戏| 蕉岭县| 涞源县| 合山市| 克东县| 呼伦贝尔市| 温泉县| 林西县| 浏阳市| 剑河县| 衡水市|