快捷導(dǎo)航

詳解Go 并發(fā)

更新時(shí)間：2020年09月03日 08:51:09 作者：百里江山

這篇文章主要介紹了Go 并發(fā)的相關(guān)資料，幫助大家更好的理解和學(xué)習(xí)go語(yǔ)言，感興趣的朋友可以了解下

golang 天生語(yǔ)言層面支持并發(fā), 非常棒的語(yǔ)言, 有時(shí)我們業(yè)務(wù)開(kāi)發(fā)時(shí), 遇到復(fù)雜場(chǎng)景, 需要用于并發(fā), 將多個(gè)請(qǐng)求使用協(xié)程組完成并發(fā), 當(dāng)遇到嵌套循環(huán),還存在上下文關(guān)系需要改造為并發(fā)請(qǐng)求, 將之前的時(shí)間復(fù)雜度為O(n^2)改為O(n)的時(shí)間復(fù)雜度, 那是否還能否并時(shí)間復(fù)雜度進(jìn)一步降為O(1)呢? 就出現(xiàn)嵌套并發(fā). 具體如何嵌套并發(fā), 如何寫(xiě). 今天就一步一步分析.

串行執(zhí)行

時(shí)間復(fù)雜度為O(n^2)
不使用并發(fā)
結(jié)果執(zhí)行時(shí)間為 9s

// 串行執(zhí)行
func SerializeRun() {
	start := time.Now()
	xx := []int{1, 2, 3}
	yy := []int{100, 200, 300}
	for _, x := range xx {
		for _, y := range yy {
			abc(x, y)
		}
	}
	fmt.Printf("串行執(zhí)行總時(shí)間:%s\n", time.Since(start))
}

func abc(x, y int) {
	time.Sleep(time.Second * 1)
	fmt.Printf("x:%d, y:%d\n", x, y)
}

執(zhí)行結(jié)果

x:1, y:100
x:1, y:200
x:1, y:300
x:2, y:100
x:2, y:200
x:2, y:300
x:3, y:100
x:3, y:200
x:3, y:300
串行執(zhí)行總時(shí)間:9.0026338s

單協(xié)程組并發(fā)

使用了協(xié)程組將O(n^2)降為O(n)
結(jié)果執(zhí)行時(shí)間為 3s

// 單并行執(zhí)行
func SingleConcurrenceRun() {
	start := time.Now()
	xx := []int{1, 2, 3}
	yy := []int{100, 200, 300}
	for _, x := range xx {
		wgg := sync.WaitGroup{}
		for _, y := range yy {
			wgg.Add(1)
			go func(x, y int) {
				defer wgg.Done()
				abc(x, y)
			}(x, y)
		}
		wgg.Wait()
	}
	fmt.Printf("單并行執(zhí)行總時(shí)間:%s\n", time.Since(start))
}
func abc(x, y int) {
	time.Sleep(time.Second * 1)
	fmt.Printf("x:%d, y:%d\n", x, y)
}

結(jié)果

x:1, y:300
x:1, y:200
x:1, y:100
x:2, y:100
x:2, y:200
x:2, y:300
x:3, y:300
x:3, y:100
x:3, y:200
單并行執(zhí)行總時(shí)間:3.0013813s

嵌套并發(fā)執(zhí)行

使用嵌套協(xié)程組執(zhí)行并發(fā).
將O(n^2)降到O(1)
結(jié)果執(zhí)行時(shí)間為 1s

// 嵌套執(zhí)行
func NestConcurrenceRun() {
	xx := []int{1, 2, 3}
	yy := []int{100, 200, 300}
	start := time.Now()
	wgg := sync.WaitGroup{}
	for _, x := range xx {
		wgg.Add(1)
		go func(x int) {
			wg := sync.WaitGroup{}
			for _, y := range yy {
				wg.Add(1)
				go func(x, y int) {
					defer wg.Done()
					abc(x, y)
				}(x, y)
			}
			wg.Wait()
			wgg.Done()
		}(x)
	}
	wgg.Wait()
	fmt.Printf("嵌套并發(fā)執(zhí)行總時(shí)間:%s\n", time.Since(start))
}
func abc(x, y int) {
	time.Sleep(time.Second * 1)
	fmt.Printf("x:%d, y:%d\n", x, y)
}

結(jié)果