Go中semaphore.Weighted实现Acquire超时打告警且保持阻塞的方法

核心思路是完全保留原信号量的阻塞等待逻辑，通过并行独立的计时协程实现超时告警，全程不干预Acquire方法本身的执行状态：

• 原Acquire调用保持传入context.TODO()不变，确保它依然会无限阻塞直到获取到信号量，不会提前返回中断流程
• 新增独立的计时检测协程，和Acquire的执行并行运行，仅在阻塞时长达到阈值时触发告警
• 通过取消信号绑定Acquire的返回时机，避免锁提前获取成功时触发误告警、避免协程资源泄漏

仅需修改原有的acquireLock函数，其余业务逻辑无需调整：

func acquireLock() {
    // 创建可取消的上下文，用于控制超时检测协程
    watchCtx, cancel := context.WithCancel(context.Background())
    // Acquire返回时自动取消检测协程
    defer cancel()

    // 启动独立的超时检测协程
    go func() {
        const warnThreshold = 5 * time.Second
        timer := time.NewTimer(warnThreshold)
        defer timer.Stop()

        select {
        // 达到告警阈值且未被取消时，输出告警日志
        case <-timer.C:
            fmt.Printf("there is a potential deadlock: semaphore acquire blocked for over %s\n", warnThreshold)
        // Acquire已返回（无论成功/失败），直接退出检测协程，不触发告警
        case <-watchCtx.Done():
            return
        }
    }()

    // 原有阻塞获取逻辑完全保持不变
    err := lock.Acquire(context.TODO(), 1)
    if err != nil {
        panic(err)
    }
}

• 禁止将带超时的上下文传入原Acquire方法：如果传入带超时的context，会导致Acquire在超时后直接返回错误，中断原有阻塞等待逻辑，不符合设计要求
• 检测协程不参与信号量的申请、释放流程：仅做计时和日志输出，不会对原信号量的互斥逻辑造成任何干扰
• 告警逻辑可按需扩展：比如在日志中加入goroutine栈信息、调用链路标识，快速定位死锁位置

内容的提问来源于stack exchange，提问作者Nathan F.