返回介绍

上卷 程序设计

中卷 标准库

下卷 运行时

源码剖析

附录

4.4.3 唤醒

发布于 2024-10-12 19:15:58 字数 1235 浏览 0 评论 0 收藏 0

每当有新 G 创建,调度器都会积极尝试其他 MP 并发执行。

// proc.go

func newproc(fn *funcval) {
	newg := newproc1(fn, gp, pc)
	runqput(_p_, newg, true)

	if mainStarted {
		wakep()
	}
}
// Tries to add one more P to execute G's.
func wakep() {
    
    // 没有空闲 P,放弃。
	if atomic.Load(&sched.npidle) == 0 {
		return
	}
    
	// 某些 MP 正在积极查找任务,也就是自旋状态。
    // 某些 M 新建或刚唤醒,还没开始找任务,也是自旋状态。
	if atomic.Load(&sched.nmspinning) != 0 || !atomic.Cas(&sched.nmspinning, 0, 1) {
		return
	}
    
	startm(nil, true)
}
// Schedules some M to run the p (creates an M if necessary).
// If p==nil, tries to get an idle P, if no idle P's does nothing.

func startm(_p_ *p, spinning bool) {
    
    // 获取闲置 P。
	if _p_ == nil {
		_p_ = pidleget()
		if _p_ == nil {
			return
		}
	}
    
    // 获取闲置 M,或新建。
	nmp := mget()
	if nmp == nil {
        
        // 关联函数 mspinning,用于设置自旋状态。
		var fn func()
		if spinning {
			// The caller incremented nmspinning, so set m.spinning in the new M.
			fn = mspinning
		}
        
        // 新建。
		newm(fn, _p_, id)
		return
	}
    
	// 设置自旋状态,以及待关联 P。
	nmp.spinning = spinning
	nmp.nextp.set(_p_)
    
    // 唤醒,重新开始调度循环。
	notewakeup(&nmp.park)
}

设置自旋状态,可避免短时间内激活多个 MP 去竞争任务。

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

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

发布评论

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