一、怎么才能讓主goroutine等待其它goroutine

方法一：讓主goroutine "sleep"一段時(shí)間

func main() {
	for i := 0; i < 10; i++ {
		go func(i int) {
			fmt.Println(i)
		}(i)
	}
	time.Sleep(time.Microsecond * 100)
}

缺點(diǎn)是：睡眠的時(shí)間很難把握。

方法二：使用通道，使用chan struct{}類型

func main() {
	num := 10
	var ch = make(chan struct{}, num)
	for i := 0; i < num; i++ {
		go func(i int) {
			fmt.Println(i)
			ch <- struct{}{}
		}(i)
	}
	for i := 0; i < num; i++ {
		<-ch
	}
}

類型字面量struct{}有些類似空接口類型interface{}，它代表了即不包含任何字段也不擁有任何方法的空結(jié)構(gòu)體類型。

struct{}類型值的表示法只有一個(gè)，即：struct{}{}。并且它占用的內(nèi)存空間是0字節(jié)，確切地說(shuō)，這個(gè)值在整個(gè)GO程序中永遠(yuǎn)都只會(huì)存在一份。

方法三：使用sync.WaitGroup

待補(bǔ)充。

二、怎么讓多個(gè)goroutine按照既定的順序運(yùn)行

package main
import (
	"fmt"
	"sync/atomic"
	"time"
)
func main() {
	num := uint32(100)
	var count uint32 = 0
	trigger := func(i uint32, fn func()) {
		for {
			if atomic.LoadUint32(&count) == i {
				fn()
				atomic.AddUint32(&count, 1)
				break
			}
			// 這里加Sleep語(yǔ)句是很有必要的
			time.Sleep(time.Microsecond)
		}
	}
	for i := uint32(0); i < num; i++ {
		go func(i uint32) {
			fn := func() {
				fmt.Println(i)
			}
			trigger(i, fn)
		}(i)
	}
	trigger(num, func() {})
}

這里的trigger函數(shù)實(shí)現(xiàn)了一種自旋（spining）。

上面的自旋中添加了time.Sleep(time.Microsecond)語(yǔ)句：

這主要是因?yàn)椋篏o 調(diào)度器在需要的時(shí)候只會(huì)對(duì)正在運(yùn)行的 goroutine 發(fā)出通知，試圖讓它停下來(lái)。但是，它卻不會(huì)也不能強(qiáng)行讓一個(gè) goroutine 停下來(lái)。

所以，如果一條 for 語(yǔ)句過(guò)于簡(jiǎn)單的話，比如這里的 for 語(yǔ)句就很簡(jiǎn)單（因?yàn)槔锩嬷挥幸粭l if 語(yǔ)句），那么當(dāng)前的 goroutine 就可能不會(huì)去正常響應(yīng)（或者說(shuō)沒(méi)有機(jī)會(huì)響應(yīng)）Go 調(diào)度器的停止通知。

因此，這里加一個(gè) sleep 是為了：在任何情況下（如任何版本的 Go、任何計(jì)算平臺(tái)下的 Go、任何的 CPU 核心數(shù)等），內(nèi)含這條 for 語(yǔ)句的這些 goroutine 都能夠正常地響應(yīng)停止通知。

不加Sleep語(yǔ)句，可能會(huì)導(dǎo)致一直搶占不到資源，也就沒(méi)有機(jī)會(huì)運(yùn)行，就可能會(huì)導(dǎo)致程序一直運(yùn)行，不會(huì)終止。

樂(lè)觀鎖：總是假設(shè)在“我”操作共享資源的過(guò)程中沒(méi)有“其他人”競(jìng)爭(zhēng)操作。如果發(fā)現(xiàn)“其他人”確實(shí)在此期間競(jìng)爭(zhēng)了，也就是發(fā)現(xiàn)假設(shè)失敗，那就等一等再操作。CAS原子操作基本上能夠體現(xiàn)出這種思想。通常，低頻的并發(fā)操作適合用樂(lè)觀鎖。樂(lè)觀鎖一般會(huì)用比較輕量級(jí)的同步方法（如原子操作），但也不是100%。注意，高頻的操作用樂(lè)觀鎖的話反而有可能影響性能，因?yàn)槎嗔艘徊?ldquo;探查是否有人與我競(jìng)爭(zhēng)”的操作（當(dāng)然了，標(biāo)準(zhǔn)的CAS操作可以把這種影響降到最低）。

悲觀鎖：總是假設(shè)在“我”操作共享資源的過(guò)程中一定有“其他人”競(jìng)爭(zhēng)操作。所以“我”會(huì)先用某種同步方法（如互斥鎖）保護(hù)我的操作。這樣的話，“我”在將要操作的時(shí)候就沒(méi)必要去探查是否有人與我競(jìng)爭(zhēng)（因?yàn)?ldquo;我”總是假設(shè)肯定有競(jìng)爭(zhēng)，而且已經(jīng)做好了保護(hù)）。通常，頻次較高的并發(fā)操作適合用悲觀鎖。不過(guò)，如果并發(fā)操作的頻次非常低，用悲觀鎖也是可以的，因?yàn)檫@種情況下對(duì)性能影響不大。

最后，一定要注意，使用任何同步方法和異步方法都首先要考慮程序的正確性，并且還要考慮程序的性能。程序的正確性一定要靠功能測(cè)試來(lái)保障，程序的性能一定要靠性能測(cè)試來(lái)保障。

到此這篇關(guān)于Go routine使用方法講解的文章就介紹到這了,更多相關(guān)Go routine內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論