Question

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

// mfinal.go

// A single goroutine runs all finalizers for a program, sequentially.
// If a finalizer must run for a long time, it should do so by starting
// a new goroutine.

func SetFinalizer(obj any, finalizer any) {

	// make sure we have a finalizer goroutine
	createfing()
}

var fingCreate uint32

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

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

// mfinal.go

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 {
		// 扣下 finq 队列。
		fb := finq
		finq = nil
        
        // 队列空，休眠。
		if fb == nil {
			gp := getg()
            
			fing = gp         // !!!            
			fingwait = true   // !!!
            
			goparkunlock(&finlock, waitReasonFinalizerWait, traceEvGoBlock, 1)
			
            continue
		}
        
        // 遍历队列。
		for fb != nil {
            
            // 遍历单个 finblock 内终结器数组。
			for i := fb.cnt; i > 0; i-- {
                
                // 提取一个 finalizer。
				f := &fb.fin[i-1]

                // 执行终结函数。
				fingRunning = true
				reflectcall(nil, unsafe.Pointer(f.fn), frame, uint32(framesz), uint32(framesz), uint32(framesz), &regs)
				fingRunning = false

				f.fn = nil
				f.arg = nil
				f.ot = nil
				atomic.Store(&fb.cnt, i-1)
			}
            
            // 下一 finblock。
			next := fb.next
            
            // 当前 block 放回缓存（finc）。
			fb.next = finc
			finc = fb
            
			fb = next
		}
	}
}

唤醒

在 schedule/findrunnable 里，会检查并尝试唤醒。

// proc.go

func findrunnable() (gp *g, inheritTime bool) {
    
    // 当 queuefinalizer 添加函数到队列时，设置 fingwake = true。
    
	if fingwait && fingwake {
        
        // 获取 fing G 并唤醒。
		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
}