返回介绍

上卷 程序设计

中卷 标准库

下卷 运行时

源码剖析

附录

4.3.5 编号

发布于 2024-10-12 19:16:05 字数 1234 浏览 0 评论 0 收藏 0

在 sched 里有个计数器,用于分配 G.goid。

// runtime2.go

type schedt struct {
    goidgen  uint64
}

考虑到多个 P 共同使用,所以每次都提取一段 "缓存" 到本地。

// proc.go

const _GoidCacheBatch = 16
// runtime2.go

type p struct {
    // Cache of goroutine ids, amortizes accesses to runtime·sched.goidgen.
    goidcache    uint64
    goidcacheend uint64
}

在 newproc1 里,通过判断本地计数是否到达尾部(goidcacheend)来决定是否新取一批过来。

就是简单的将 sched.goidgen 增加 16,表示取走 16 个连续号。

这样就保证了多个 P 之间 G.id 的唯一性。

注意,G 对象复用时,会重新赋予 id。

通过编号,我们大概能判断进程里共计创建过多少任务。

// proc.go

func newproc1(fn *funcval, argp unsafe.Pointer, narg int32, callergp *g, callerpc uintptr) *g {
    if _p_.goidcache == _p_.goidcacheend {
        
        // Sched.goidgen is the last allocated id,
        // this batch must be [sched.goidgen+1, sched.goidgen+GoidCacheBatch].
        // At startup sched.goidgen=0, so main goroutine receives goid=1.
        
        _p_.goidcache = atomic.Xadd64(&sched.goidgen, _GoidCacheBatch)
        _p_.goidcache -= _GoidCacheBatch - 1
        _p_.goidcacheend = _p_.goidcache + _GoidCacheBatch
    }
    
    newg.goid = int64(_p_.goidcache)
    _p_.goidcache++
}

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
    原文