上卷 程序设计
中卷 标准库
- 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.3.3 复用
对于执行结束的 dead G 并不会释放,而是缓存在 P 本地或全局,以待复用。
// runtime2.go type schedt struct { // Global cache of dead G's. gFree struct { stack gList // Gs with stacks noStack gList // Gs without stacks n int32 } } type p struct { // Available G's (status == Gdead) gFree struct { gList n int32 } }
gList 是一个以 G.schedlink 构建的链表。
先从 P 本地链表提取,准备复用。
如果没有,那么先全局批量提取一些填充到本地。
// proc.go // Get from gfree list. // If local list is empty, grab a batch from global list. func gfget(_p_ *p) *g { retry: // 如果本地复用链表为空,则从全局转移一批过来。 if _p_.gFree.empty() && (!sched.gFree.stack.empty() || !sched.gFree.noStack.empty()) { // 尽可能让本地凑足 32 个。 for _p_.gFree.n < 32 { // 优先选择有栈内存的。 gp := sched.gFree.stack.pop() if gp == nil { gp = sched.gFree.noStack.pop() if gp == nil { break } } sched.gFree.n-- _p_.gFree.push(gp) _p_.gFree.n++ } // 转移过后,重试!确保本地队列不为空。 goto retry } // 从本地提取。 gp := _p_.gFree.pop() if gp == nil { return nil } _p_.gFree.n-- // 补上栈内存。 if gp.stack.lo == 0 { systemstack(func() { gp.stack = stackalloc(_FixedStack) }) gp.stackguard0 = gp.stack.lo + _StackGuard } return gp }
执行完的被放回 P 本地链表。
如果本地链表过长,则转移一批到全局,供其他 P 使用。
// proc.go // Put on gfree list. // If local list is too long, transfer a batch to the global list. func gfput(_p_ *p, gp *g) { // 如果栈内存发生过变化(扩容),那么释放栈内存。 stksize := gp.stack.hi - gp.stack.lo if stksize != _FixedStack { // non-standard stack size - free it. stackfree(gp.stack) gp.stack.lo = 0 gp.stack.hi = 0 gp.stackguard0 = 0 } // 存入本地链表。 _p_.gFree.push(gp) _p_.gFree.n++ // 如果本地数量超过 64,则转移一批到全局。 if _p_.gFree.n >= 64 { // 本地只留 32 个。 for _p_.gFree.n >= 32 { _p_.gFree.n-- gp = _p_.gFree.pop() // 根据栈内存是否释放选择目标位置。 if gp.stack.lo == 0 { sched.gFree.noStack.push(gp) } else { sched.gFree.stack.push(gp) } sched.gFree.n++ } } }
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论