看一段代码
func main() {
wg := sync.WaitGroup{}
wg.Add(20)
for i := 0; i < 10; i++ {
go func() {
fmt.Println("A: ", i)
wg.Done()
}()
}
for i := 0; i < 10; i++ {
go func(i int) {
fmt.Println("B: ", i)
wg.Done()
}(i)
}
wg.Wait()
}
输出结果:
A: 4
A: 10
A: 10
A: 10
B: 2
A: 10
A: 10
A: 10
B: 9
B: 3
B: 4
B: 5
B: 6
A: 10
B: 0
B: 1
A: 10
A: 10
B: 8
B: 7
结论:
A与B所在的协程执行顺序不确定,A输出的大部分为10,可能输出i的中间值
B输出的是0到9的值,输出顺序也是不确定的。
这是因为A与B分布在不同的goroutine队列
再试下面的代码
func main() {
runtime.GOMAXPROCS(1) //设置协程调度只有一个P
wg := sync.WaitGroup{}
wg.Add(20)
for i := 0; i < 10; i++ {
go func() {
fmt.Println("A: ", i)
wg.Done()
}()
}
for i := 0; i < 10; i++ {
go func(i int) {
fmt.Println("B: ", i)
wg.Done()
}(i)
}
wg.Wait()
}
输出结果:
B: 9
A: 10
A: 10
A: 10
A: 10
A: 10
A: 10
A: 10
A: 10
A: 10
A: 10
B: 0
B: 1
B: 2
B: 3
B: 4
B: 5
B: 6
B: 7
B: 8
结论:
多次运行结果都是上面一样。先输出B: 9,然后10个A: 10,然后B输出0到8
runtime. GOMAXPROCS(1) 强行指定了只创建一个 “P” 来处理并发,这使得例子中的 20 个 goroutine 会是串行的
编译器会把 go 后面跟着的函数与参数都打包成g对象,等待系统调度。
再试下面代码
func main() {
runtime.GOMAXPROCS(1)
for i := 0; i < 10; i++ {
go print(i)
}
time.Sleep(time.Second)
}
输出结果:0 1 2 3 ... 8 9 注意输出的不是10个10
再如下
func main() {
runtime.GOMAXPROCS(1)
for i := 0; i < 10; i++ {
go println(i)
}
runtime.Gosched()
time.Sleep(time.Second)
}
输出结果:
9
0
1
2
3
4
5
6
7
8
有疑问加站长微信联系(非本文作者)