Go语言如何按间隔调用Ticker？Web服务定时执行sendData问题求助

解决你的定时任务问题 #

你的核心问题是没搞清楚http.ListenAndServe是阻塞调用，以及当前schedule的使用逻辑不符合Web服务的运行需求。

修改后的正确代码 #

你需要将Ticker的启动逻辑依托schedule内部的goroutine运行，让定时任务和Web服务并行执行，同时不需要手动sleep和提前关闭done channel（仅在服务退出时优雅停止Ticker即可）：

package main

import (
    "log"
    "net/http"
    "time"
)

func headers(w http.ResponseWriter, r *http.Request) {
    // 你的原有请求处理逻辑
}

func sendData() {
    // 你的文件遍历与数据发送逻辑
    log.Println("执行sendData定时任务")
}

func schedule(f func(), interval time.Duration, done <-chan bool) *time.Ticker {
    ticker := time.NewTicker(interval)
    go func() {
        for {
            select {
            case <-ticker.C:
                f()
            case <-done:
                return
            }
        }
    }()
    return ticker
}

func main() {
    http.HandleFunc("/data", headers)
    log.Printf("Ready for data ...%d", 8080)

    // 初始化done channel，用于优雅停止Ticker
    done := make(chan bool)
    // 启动定时任务：每分钟执行一次sendData
    ticker := schedule(sendData, time.Minute, done)
    // 确保服务退出时清理Ticker资源
    defer func() {
        close(done)
        ticker.Stop()
    }()

    // 启动Web服务（阻塞调用，直到服务停止）
    if err := http.ListenAndServe(":8080", nil); err != nil && err != http.ErrServerClosed {
        log.Fatalf("Web服务启动失败: %v", err)
    }
}

原写法错误原因 #

• 放在第2行后：你原本的代码调用了time.Sleep(60 * time.Second)，会阻塞main goroutine，导致http.ListenAndServe迟迟无法执行，Web服务无法启动；60秒后关闭done channel会直接终止Ticker，之后才启动Web服务，完全不符合“持续每分钟执行sendData”的需求。
• 放在第3行后：http.ListenAndServe是阻塞函数，会一直运行到服务停止，后续代码永远不会被执行，Ticker根本没机会启动。

Ticker内部工作原理 #

time.Ticker是Go标准库提供的重复定时触发工具，核心运行逻辑如下：

1. 初始化：调用time.NewTicker(interval)时，会创建一个内部goroutine，同时生成一个带缓冲的channel（ticker.C）。
2. 定时触发：内部goroutine会按照指定间隔，周期性地将当前时间发送到ticker.C中。这个间隔基于系统时钟自动调整，避免因任务执行耗时导致的间隔漂移（比如任务执行了10秒，下一次触发仍会落在原定时间点，而非任务结束后再等interval）。
3. 停止机制：调用ticker.Stop()会终止内部定时goroutine，不再往channel发送新信号，但已发送到channel中的信号仍会被接收，因此通常配合done channel实现循环的优雅退出。
4. 注意点：如果任务执行时间超过interval，Ticker会累积触发信号（因channel有缓冲），导致任务被连续执行；若不想出现这种情况，可以在每次执行任务前先清空channel中的剩余信号，或者改用time.After在任务结束后重新计时。

内容的提问来源于stack exchange，提问作者celcin