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é)果
x:1, y:200
x:3, y:300
x:3, y:200
x:1, y:300
x:2, y:200
x:1, y:100
x:2, y:300
x:2, y:100
x:3, y:100
嵌套并發(fā)執(zhí)行總時(shí)間:1.0023542s
以上就是詳解Go 并發(fā)的詳細(xì)內(nèi)容，更多關(guān)于Go 并發(fā)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
您可能感興趣的文章:- 詳解Go多協(xié)程并發(fā)環(huán)境下的錯(cuò)誤處理
- Django高并發(fā)負(fù)載均衡實(shí)現(xiàn)原理詳解
- golang并發(fā)編程的實(shí)現(xiàn)
- 一百行Golang代碼實(shí)現(xiàn)簡(jiǎn)單并發(fā)聊天室
- 基于Django的樂(lè)觀鎖與悲觀鎖解決訂單并發(fā)問(wèn)題詳解
- django解決訂單并發(fā)問(wèn)題【推薦】
- golang并發(fā)ping主機(jī)的方法
- golang并發(fā)下載多個(gè)文件的方法
- Go并發(fā)調(diào)用的超時(shí)處理的方法
