golang 天生语言层面支持并发, 非常棒的语言, 有时我们业务开发时, 遇到复杂场景, 需要用于并发, 将多个请求使用协程组完成并发, 当遇到嵌套循环,还存在上下文关系需要改造为并发请求, 将之前的时间复杂度为O(n^2)改为O(n)的时间复杂度, 那是否还能否并时间复杂度进一步降为O(1)呢? 就出现嵌套并发. 具体如何嵌套并发, 如何写. 今天就一步一步分析.
串行执行
// 串行执行 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("串行执行总时间:%s\n", time.Since(start)) } func abc(x, y int) { time.Sleep(time.Second * 1) fmt.Printf("x:%d, y:%d\n", x, y) }
执行结果
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
串行执行总时间:9.0026338s
单协程组并发
// 单并行执行 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("单并行执行总时间:%s\n", time.Since(start)) } func abc(x, y int) { time.Sleep(time.Second * 1) fmt.Printf("x:%d, y:%d\n", x, y) }
结果
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
单并行执行总时间:3.0013813s
嵌套并发执行
// 嵌套执行 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("嵌套并发执行总时间:%s\n", time.Since(start)) } func abc(x, y int) { time.Sleep(time.Second * 1) fmt.Printf("x:%d, y:%d\n", x, y) }
结果
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
嵌套并发执行总时间:1.0023542s
以上就是详解Go 并发的详细内容,更多关于Go 并发的资料请关注脚本之家其它相关文章!
标签:德州 西双版纳 广西 调研邀请 庆阳 太原 贵阳 阿克苏
巨人网络通讯声明:本文标题《详解Go 并发》,本文关键词 详解,并发,详解,并发,;如发现本文内容存在版权问题,烦请提供相关信息告之我们,我们将及时沟通与处理。本站内容系统采集于网络,涉及言论、版权与本站无关。上一篇:详解Go 结构体格式化输出