上卷 程序设计
中卷 标准库
- bufio 1.18
- bytes 1.18
- io 1.18
- container 1.18
- encoding 1.18
- crypto 1.18
- hash 1.18
- index 1.18
- sort 1.18
- context 1.18
- database 1.18
- connection
- query
- queryrow
- exec
- prepare
- transaction
- scan & null
- context
- tcp
- udp
- http
- server
- handler
- client
- h2、tls
- url
- rpc
- exec
- signal
- embed 1.18
- plugin 1.18
- reflect 1.18
- runtime 1.18
- KeepAlived
- ReadMemStats
- SetFinalizer
- Stack
- sync 1.18
- atomic
- mutex
- rwmutex
- waitgroup
- cond
- once
- map
- pool
- copycheck
- nocopy
- unsafe 1.18
- fmt 1.18
- log 1.18
- math 1.18
- time 1.18
- timer
下卷 运行时
源码剖析
附录
文章来源于网络收集而来,版权归原创者所有,如有侵权请及时联系!
4.4.2 闲置
如果 MP 没找到可执行任务,那么就会进入闲置状态。
// proc.go func schedule() { ... top: // 尝试 n 种任务查找方式... if gp == nil { gp, inheritTime = findrunnable() // blocks until work is available } execute(gp, inheritTime) }
// Finds a runnable goroutine to execute. // Tries to steal from other P's, get g from local or global queue, poll network. func findrunnable() (gp *g, inheritTime bool) { top: // local runq ... // global runq ... // poll network ... // steal work from other Ps ... // 解除关联 P,放入空闲列表。 if releasep() != _p_ { throw("findrunnable: wrong p") } pidleput(_p_) // 当前 M 休眠。放入闲置列表,直到再次启用。 stopm() goto top }
// Stops execution of the current m until new work is available. func stopm() { _g_ := getg() // 放入闲置列表。 mput(_g_.m) // 休眠。 mPark() // 关联由唤醒者提供的 P。 acquirep(_g_.m.nextp.ptr()) _g_.m.nextp = 0 }
调度器使用专门的链表管理闲置 M。
// runtime2.go type schedt struct { midle muintptr // idle m's waiting for work nmidle int32 // number of idle m's waiting for work }
// proc.go // Put mp on midle list. func mput(mp *m) { mp.schedlink = sched.midle sched.midle.set(mp) sched.nmidle++ }
// Try to get an m from midle list. func mget() *m { mp := sched.midle.ptr() if mp != nil { sched.midle = mp.schedlink sched.nmidle-- } return mp }
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论