Go使用context超时控制定时任务避免执行重叠问题排查

你的代码无法按预期触发超时，核心问题有两个：

• select的default分支是非阻塞逻辑，一旦进入就会直接执行time.Sleep(executionTime)——这个睡眠操作是不可中断的，执行期间完全不会检查ctx.Done()的取消信号，哪怕context已经超时，也要等整个睡眠结束才会继续往下走，自然走不到超时分支。
• 创建带超时的context后没有调用返回的cancel函数，会造成定时器资源泄漏，context关联的资源必须等到超时时间到才会被回收。

另外你写的外层for循环是多余的，逻辑只会执行一次就return，没有任何循环作用。

核心思路是把实际业务逻辑放到独立goroutine中执行，用select同时监听业务完成信号和context超时信号，谁先返回就处理对应的分支：

package main

import (
	"context"
	"fmt"
	"math/rand"
	"time"
)

func main() {
	fmt.Println("startProcessing")
	go startProcessing()

	time.Sleep(time.Second * 60)
	fmt.Println("endProcessing after 60s")
}

func startProcessing() {
	ticker := time.NewTicker(3 * time.Second)
	defer ticker.Stop() // 程序退出前停止ticker避免资源泄漏
	for range ticker.C {
		ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second - time.Millisecond)
		fmt.Println("start doSomething")
		doSomething(ctx)
		cancel() // 任务执行完成（不管是正常结束还是超时）立刻释放context资源
	}
}

func doSomething(ctx context.Context) {
	executionTime := time.Duration(rand.Intn(5)+1) * time.Second
	done := make(chan struct{})

	// 模拟实际业务逻辑执行
	go func() {
		time.Sleep(executionTime)
		fmt.Printf("did something in %s\n", executionTime)
		close(done)
	}()

	select {
	case <-ctx.Done():
		fmt.Printf("timed out after %s\n", executionTime)
		return
	case <-done:
		return
	}
}

• 不要在select的default分支里放长时间阻塞的代码，进入default分支后就脱离了select的事件监听范围，无法响应其他case的信号。
• 如果要100%避免任务重叠，可以在startProcessing里加互斥锁，或者用状态标记判断上一次任务是否已经完全退出，再启动新的任务。
• Go没有强制杀死运行中goroutine的能力，实际业务中所有耗时操作（比如数据库查询、IO调用）都要主动接收ctx.Done()信号做退出处理，否则会出现孤儿goroutine占用资源。

内容的提问来源于stack exchange，提问作者Fabio B.