分享
理解go func背后发生了什么
无上法门 · · 17984 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
看一段代码
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
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信17984 次点击
下一篇:athens
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
看一段代码
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