Question

创建专门的 goroutine 用于执行终结函数。

在 SetFinalizer 中被调用。

// mfinal.go

func createfing() {
    // start the finalizer goroutine exactly once
    if fingCreate == 0 && atomic.Cas(&fingCreate, 0, 1) {
        go runfinq()
    }
}

两个全局标记，分别代表唤醒和休眠。

var fingwait bool
var fingwake bool

var fing *g         // goroutine that runs finalizers

// mfinal.go

// This is the goroutine that runs all of the finalizers

func runfinq() {

    for {
        
        // 直接取下整个待运行队列，避免并发干扰。
        fb := finq
        finq = nil
        
        // 队列空，休眠。
        // 以后由 findrunnable 调用 wakefing 唤醒。
        if fb == nil {
            gp := getg()
            fing = gp            // 保存当前 G。
            fingwait = true      // 设置休眠标记。
            
            goparkunlock(&finlock, waitReasonFinalizerWait, traceEvGoBlock, 1)
            continue
        }
        
        // 遍历执行队列。
        for fb != nil {
            
            // 遍历单个 finblock 内终结器数组。
            for i := fb.cnt; i > 0; i-- {
                f := &fb.fin[i-1]
                
                // 执行。
                fingRunning = true
                reflectcall(nil, unsafe.Pointer(f.fn), frame, uint32(framesz), uint32(framesz))
                fingRunning = false
                
                atomic.Store(&fb.cnt, i-1)
            }
            
            // 调整队列，遍历下个块。
            // 当前块（fb）放回缓存（finc）头部。
            next := fb.next
            fb.next = finc
            finc = fb
            fb = next
        }
    }
}

唤醒条件：已休眠，外加队列有内容（queuefinalizer）。

// proc.go

func findrunnable() (gp *g, inheritTime bool) {
    if fingwait && fingwake {
        if gp := wakefing(); gp != nil {
            ready(gp, 0, true)
        }
    }
}

// mfinal.go

func wakefing() *g {
    var res *g
    
    if fingwait && fingwake {
        fingwait = false
        fingwake = false
        res = fing
    }
    
    return res
}