golang 天生語言層面支持并發(fā), 非常棒的語言, 有時我們業(yè)務(wù)開發(fā)時, 遇到復(fù)雜場景, 需要用于并發(fā), 將多個請求使用協(xié)程組完成并發(fā), 當(dāng)遇到嵌套循環(huán),還存在上下文關(guān)系需要改造為并發(fā)請求, 將之前的時間復(fù)雜度為O(n^2)改為O(n)的時間復(fù)雜度, 那是否還能否并時間復(fù)雜度進一步降為O(1)呢? 就出現(xiàn)嵌套并發(fā). 具體如何嵌套并發(fā), 如何寫. 今天就一步一步分析.
串行執(zhí)行
- 時間復(fù)雜度為O(n^2)
- 不使用并發(fā)
- 結(jié)果執(zhí)行時間為 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í)行總時間:%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í)行總時間:9.0026338s
單協(xié)程組并發(fā)
- 使用了協(xié)程組將O(n^2)降為O(n)
- 結(jié)果執(zhí)行時間為 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í)行總時間:%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í)行總時間:3.0013813s
嵌套并發(fā)執(zhí)行
- 使用嵌套協(xié)程組執(zhí)行并發(fā).
- 將O(n^2)降到O(1)
- 結(jié)果執(zhí)行時間為 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í)行總時間:%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í)行總時間:1.0023542s
以上就是詳解Go 并發(fā)的詳細(xì)內(nèi)容，更多關(guān)于Go 并發(fā)的資料請關(guān)注腳本之家其它相關(guān)文章！
您可能感興趣的文章:- 詳解Go多協(xié)程并發(fā)環(huán)境下的錯誤處理
- Django高并發(fā)負(fù)載均衡實現(xiàn)原理詳解
- golang并發(fā)編程的實現(xiàn)
- 一百行Golang代碼實現(xiàn)簡單并發(fā)聊天室
- 基于Django的樂觀鎖與悲觀鎖解決訂單并發(fā)問題詳解
- django解決訂單并發(fā)問題【推薦】
- golang并發(fā)ping主機的方法
- golang并發(fā)下載多個文件的方法
- Go并發(fā)調(diào)用的超時處理的方法
