Question

定时释放由独立的 goroutine 执行。

// mgc.go

func gcenable() {
    go bgscavenge(c)
}

// proc.go

// The main goroutine.
func main() {
    gcenable()
}

不仅考虑释放总量，还兼顾操作频率带来的开销。

相比 5 分钟闲置更积极，且比 1.13 更细腻。

该 G 以循环方式执行，单次释放足量内存。如释放未果，表示当前没有 “多余” 物理内存，阻塞后等待手工唤醒，否则以定时器唤醒。

// mgcscavenge.go

func bgscavenge(c chan int) {
    
    scavenge.g = getg()
    scavenge.parked = true
    
    // 定时器，唤醒下面循环里的 sleep 操作。
    scavenge.timer = new(timer)
    scavenge.timer.f = func(_ interface{}, _ uintptr) {
        wakeScavenger()
    }
    
    // 阻塞。
    goparkunlock(&scavenge.lock, waitReasonGCScavengeWait, traceEvGoBlock, 1)
    
    // 按页循环释放。
    for {
        systemstack(func() {
            
            // 条件阈值。
            retained, goal := heapRetained(), mheap_.scavengeGoal
            if retained <= goal {
                return
            }
            
            // 单次释放足够物理内存，计算耗时。
            start := nanotime()
            released = mheap_.pages.scavenge(physPageSize, true)
            crit = float64(nanotime() - start)
        })
        
        // 没能释放内存，阻塞。（手工唤醒）
        if released == 0 {
            scavenge.parked = true
            goparkunlock(&scavenge.lock, waitReasonGCScavengeWait, traceEvGoBlock, 1)
            continue
        }
        
        // 计算并调整定时器间隔。
        crit *= 1 + scavengeCostRatio
        adjust := scavengeEWMA / idealFraction
        sleepTime := int64(adjust * crit / (scavengePercent / 100.0))
        
        // 释放足量内存，休眠。（定时器唤醒）
        slept := scavengeSleep(sleepTime)
        
        ...
    }
}

休眠和唤醒操作。

sysmon、finishsweep_m 会执行手工唤醒操作。

func scavengeSleep(ns int64) int64 {
    start := nanotime()
    resetTimer(scavenge.timer, start+ns)
    
    scavenge.parked = true
    goparkunlock(&scavenge.lock, waitReasonSleep, traceEvGoSleep, 2)
    
    return nanotime() - start
}

func wakeScavenger() {
    if scavenge.parked {
        stopTimer(scavenge.timer)
        scavenge.parked = false
        
        // 将 scavenge.g 放回待运行队列。
        var list gList
        list.push(scavenge.g)
        injectglist(&list)
    }
}