协程调度顺序 | 清澄秋爽

本文是对卷卷面试题的学习与记录

go 关键字会被编译器转化为对runtime.newproc函数的调用。该函数的主要逻辑：先切换到系统栈，然后调用newproc1函数，分配并初始化一个新的g，再通过runqput把新的g添加到当前P的本地runq中。

package main

import (
	"runtime"
	"sync"
)

func main() {

	// 任一时刻，只允许一个M执行Go代码； 就像单核CPU上的多线程那样
	runtime.GOMAXPROCS(1)

	var wg sync.WaitGroup

	wg.Add(3)

	go func(n int) {
		println(n)
		wg.Done()
	}(1)

	go func(n int) {
		println(n)
		wg.Done()
	}(2)

	go func(n int) {
		println(n)
		wg.Done()
	}(3)

	wg.Wait()

}

输出:

1
2
3

3
1
2

之所以如此，是因为 P不仅有一个本地runq，还有一个runnext字段，用来保存下次要运行的g。 newproc1中调用runqput时会用到这个runnext

调度goroutine执行时，通过runqget获取待执行的g。runqget也会对runnext特殊处理：优先调度runnext这里记录的g，再按顺序调度本地runq中记录的g

所以是3-1-2

如果创建更多的goroutine，结果也如此吗？

package main

import (
	"runtime"
	"sync"
)

func main() {

	// 任一时刻，只允许一个M执行Go代码； 就像单核CPU上的多线程那样
	runtime.GOMAXPROCS(1)

	var wg sync.WaitGroup

	for i := 1; i <= 280; i++ {
		wg.Add(1)
		go func(n int) {
			println(n)
			wg.Done()
		}(i)
	}

	wg.Wait()

}