GoLang使goroutine停止的五種方法實例

更新時間：2022年07月14日 15:28:04 作者：GoGo在努力

goroutine是Go并行設計的核心,下面這篇文章主要給大家介紹了關于GoLang使goroutine停止的五種方法,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下

1.goroutine停止介紹

goroutine是Go語言實現(xiàn)并發(fā)編程的利器，簡單的一個指令go function就能啟動一個goroutine；

但是，Go語言并沒有提供終止goroutine的接口，也就是說，我們不能從外部去停止一個goroutine，只能由goroutine內部退出(main函數(shù)終止除外)；

我們有很多情況下需要主動關閉goroutine，如需要實現(xiàn)一個系統(tǒng)自動熔斷的功能就需要主動關閉goroutine

2.goroutine停止的5種方法

2.1使用for-range

for-range從channel上接收值，直到channel關閉，該結構在Go并發(fā)編程中很常用，這對于從單一通道上獲取數(shù)據(jù)去執(zhí)行某些任務是十分方便的

2.2使用for-select(向退出通道發(fā)出退出信號)

當channel比較多時，for-range結構借不是很方便了；

Go語言提供了另外一種和channel相關的語法: select；

select能夠讓goroutine在多個通信操作上等待(可以理解為監(jiān)聽多個channel)；

由于這個特性，for-select結構在Go并發(fā)編程中使用的頻率很高；

我在使用Go的開發(fā)中，這是我用的最多的一種組合形式:

for {<!--{C}%3C!%2D%2D%20%2D%2D%3E-->
select {<!--{C}%3C!%2D%2D%20%2D%2D%3E-->
}
}

對于for-select結構，一般我會定義一個特定的退出通道，用于接收退出的信號，如quit

2.3使用for-select(關閉退出通道)

當我們就需要向quit通道中發(fā)送100次數(shù)據(jù)，如果再用以上的代碼就很麻煩，有一個很簡單的方法，關閉channel，這樣所有監(jiān)聽quit channel的goroutine就都會收到關閉信號,上面的代碼只要做一個很小的替換就能工作

2.4使用for-select(關閉多個channel)

如果select上監(jiān)聽了多個通道，需要所有的通道都關閉后才能結束goroutine，這里就利用select的一個特性，select不會在nil的通道上進行等待，因此將channel賦值為nil即可，此外，還需要利用channel的ok值

var wg sync.WaitGroup
func worker(in1, in2 <-chan int) {
	defer wg.Done()
	for {
		select {
		case v, ok := <-in1:
			if !ok {
				fmt.Println("收到退出信號")
				in1 = nil
			}
			// do something
			fmt.Println(v)
		case v, ok := <-in2:
			if !ok {
				fmt.Println("收到退出信號")
				in2 = nil
			}
			// do something
			fmt.Println(v)
		}
		// select已經結束，我們需要判斷兩個通道的狀態(tài)
		// 都為nil則結束當前goroutine
		if in1 == nil && in2 == nil {
			return
		}
	}
}
func main() {
	in1 := make(chan int) // 退出通道，接收
	in2 := make(chan int)
	wg.Add(2)
	go worker(in1, in2)
	go worker(in2, in2)
	for i := 0; i < 3; i++ {
		in1 <- i
		time.Sleep(1 * time.Second)
		in2 <- i
	}
	close(in1)
	close(in2)
	wg.Wait()
}