Golang中ContextWithTimeout的ctx.Done未被调用的原因分析

这也是我所想的。我原来的代码实际上是在默认情况下读取一些字节，并且会等待至少一个字节100毫秒。我使用bytes.Buffer为读取器编写了一个模拟，并在Read方法内部放置了100毫秒的等待来模拟该行为。在运行测试套件时，它会间歇性地失败，但单独运行时总是通过。也许100毫秒的等待时间不足以让Go处理ctx->Done。

func main() {
    fmt.Println("hello world")
}

你的代码中，ctx.Done() 确实会在超时后被触发，但问题在于 default 分支。在 Go 的 select 语句中，如果多个 case 同时就绪，会随机选择一个执行。然而，default 分支是非阻塞的：只要没有其他 case 就绪，select 就会立即执行 default。在你的循环中，超时发生前，ctx.Done() 通道没有数据，因此每次循环都会进入 default 分支，打印 .。由于循环没有休眠或阻塞操作，它会极快地重复执行，可能在你看到超时输出前就已经打印了大量 .，甚至可能看起来像卡住。

实际上，超时确实会发生，ctx.Done() 也会被调用，但你需要让循环有机会检查到它。例如，在 default 分支中添加一个短暂的休眠，这样 CPU 就不会被完全占用，超时事件就有机会被处理：

package main

import (
    "context"
    "fmt"
    "time"
)

func main() {
    ctx, cancel := context.WithTimeout(context.TODO(), time.Second)
    defer cancel()
    for {
        select {
        case <-ctx.Done():
            fmt.Println("Ended at:", time.Now())
            return
        default:
            fmt.Println(".")
            time.Sleep(100 * time.Millisecond) // 添加休眠
        }
    }
}

或者，更常见的做法是移除 default 分支，让 select 阻塞等待 ctx.Done()，但这样循环就不会执行其他操作。根据你的需求，如果需要在超时前执行任务，可以结合其他通道或条件。例如，使用 time.Ticker 定期执行任务：

package main

import (
    "context"
    "fmt"
    "time"
)

func main() {
    ctx, cancel := context.WithTimeout(context.TODO(), time.Second)
    defer cancel()
    ticker := time.NewTicker(100 * time.Millisecond)
    defer ticker.Stop()
    for {
        select {
        case <-ctx.Done():
            fmt.Println("Ended at:", time.Now())
            return
        case <-ticker.C:
            fmt.Println(".")
        }
    }
}

这样，循环会每 100 毫秒打印一次 .，并在超时时退出。第一个代码示例中，添加 time.Sleep 后，你应该能看到 Ended at: 输出，证明 ctx.Done() 被正确调用。