Go中的调度器(4)--goroutine状态转移

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

func newproc1(fn *funcval, argp unsafe.Pointer, narg int32, callergp *g, callerpc uintptr) {
  // --snip--
  // 获取当前g所在的p，从p中创建一个新g(newg)
  _p_ := _g_.m.p.ptr()
  newg := gfget(_p_)
  // --snip--
  // 设置Goroutine状态为Grunnable
  casgstatus(newg, _Gdead, _Grunnable)
  // --snip--
  // // 新创建的g添加到run队列中
  runqput(_p_, newg, true)
  // --snip--
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

func ready(gp *g, traceskip int, next bool) {
  // --snip--
  // 获取current g
  _g_ := getg()
  // 将状态从Gwaiting转换至Grunnable
  casgstatus(gp, _Gwaiting, _Grunnable)
  // 添加到运行队列中
  runqput(_g_.m.p.ptr(), gp, next)
  // --snip--
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

// One round of scheduler: find a runnable goroutine and execute it.
// Never returns.
func schedule() {
  // --snip--
  // 挑一个可运行的g，并执行
  if gp == nil {
    gp, inheritTime = findrunnable() // blocks until work is available
  }
  // --snip--
  execute(gp, inheritTime)
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

// Schedules gp to run on the current M.
func execute(gp *g, inheritTime bool) {
  // 将当前g的M切换到新的g上
  _g_ := getg()
  _g_.m.curg = gp
  gp.m = _g_.m
  // 将Grunnable状态变更为Grunning
  casgstatus(gp, _Grunnable, _Grunning)
  // --snip--
  // 真正执行goroutine
  gogo(&gp.sched)
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

func reentersyscall(pc, sp uintptr) {
	_g_ := getg()
	// --snip--
	casgstatus(_g_, _Grunning, _Gsyscall)
	// --snip--
  // 将m和p分离
	pp := _g_.m.p.ptr()
	pp.m = 0
	_g_.m.oldp.set(pp)
	_g_.m.p = 0
	// --snip--
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

func exitsyscall() {
  _g_ := getg()
  // --snip--
  // 如果P还存在则重新获取P
  if exitsyscallfast(oldp) {
    // --snip--
    casgstatus(_g_, _Gsyscall, _Grunning)
    // --snip--
    return
  }
  // --snip--
  // 如果P不存在则Gsyscall->Grunnable
  mcall(exitsyscall0)
  // --snip--
}

1
2
3
4
5
6

// park continuation on g0.
func park_m(gp *g) {
  // --snip--
  casgstatus(gp, _Grunning, _Gwaiting)
	// --snip--
}

1
2
3
4

func gopark(unlockf func(*g, unsafe.Pointer) bool, lock unsafe.Pointer, reason waitReason, traceEv byte, traceskip int) {
	// --snip--
  mcall(park_m)
}