Function acquirePrewarmed

controller/prewarm.go:98–144

acquirePrewarmed 优先从预热池取出可用连接。

(addr string)

// acquirePrewarmed 优先从预热池取出可用连接。
func acquirePrewarmed(addr string) (net.Conn, bool) {
	poolAny, ok := prewarmPools.Load(addr)
	if !ok {
		return nil, false
	}
	pool := poolAny.(*prewarmPool)
	pool.mu.Lock()
	defer pool.mu.Unlock()
	n := len(pool.idle)
	if n == 0 {
		pool.ensureLocked()
		return nil, false
	}
	conn := pool.idle[n-1]
	pool.idle = pool.idle[:n-1]
	// 动态扩容逻辑：
	// 需求：一旦“剩余预热可用连接” < desired 的 1/4，立即触发再次预热；新增数量 = 当前活跃使用中的连接数 * 2。
	// 当前活跃使用中的连接数近似估算：active = desired - idleLen(取出后) - warming
	// 然后 desired += active*2 (至少 1)，并受 prewarmPerTargetMax 限制。
	// 说明：这里不做回缩，保持简单；若未来需要收缩可添加基于空闲率的定时回收策略。
	remaining := len(pool.idle)                         // 取出后剩余 idle 数
	if pool.desired > 0 && remaining*4 < pool.desired { // 剩余 < 1/4 触发扩容
		oldDesired := pool.desired
		active := pool.desired - remaining - pool.warming
		if active < 0 {
			active = 0
		}
		growth := active * 2
		if growth < 1 {
			growth = 1
		}
		pool.desired += growth
		if pool.desired > prewarmPerTargetMax {
			pool.desired = prewarmPerTargetMax
		}
		utils.Logger.Debug("预热动态扩容",
			zap.String("target", pool.addr),
			zap.Int("remainingIdle", remaining),
			zap.Int("activeApprox", active),
			zap.Int("warming", pool.warming),
			zap.Int("growth", growth),
			zap.Int("oldDesired", oldDesired),
			zap.Int("newDesired", pool.desired))
	}
	pool.ensureLocked()
	return conn, true
}

// outboundDial 先尝试预热池，失败再发起新建连接。
// 之前返回 (conn, usedFlag, error)，由于当前不再区分来源，精简为 (conn, error)。