在 Web 应用程序中运行计划任务

Question

我想每 5 分钟运行一次任务来更新网站上的统计信息，而不阻塞 HTTP 服务器。

我刚刚通过工作人员示例添加了基本的 HTTP 服务器逻辑。如果我添加了这样的多个任务，这被认为是不好的做法还是有更好的方法？

package main

import (

    "fmt"

    "net/http"

    "time"

)

func Home(w http.ResponseWriter, r *http.Request) {

    fmt.Fprintf(w, "Home page")

}

func schedule(f func(), interval time.Duration) *time.Ticker {

    ticker := time.NewTicker(interval)

    go func() {

        for range ticker.C {

            f()

        }

    }()

    return ticker

}

func longRunningTask() {

    fmt.Println("Long running task")

}

func main() {

    schedule(longRunningTask, time.Second*5)

    http.HandleFunc("/", Home)

    http.ListenAndServe("127.0.0.1:8080", nil)

}

Answer 1

您的实现与 Go 中的计划作业/任务非常相似。有一些类似 cron 的库可以让您更好地控制任务，但在大多数情况下，带有循环的简单 goroutine 就足够了。以下是根据您的需求增加复杂性的更多示例：永远运行一个任务，每次运行之间等待 5 秒。无法停止并且不考虑任务的运行时间。这是最简单的形式，也是最常见的形式。go func() {&nbsp; &nbsp; for {&nbsp; &nbsp; &nbsp; &nbsp; task()&nbsp; &nbsp; &nbsp; &nbsp; <-time.After(5 * time.Second)&nbsp; &nbsp; }}()与以前相同，只是现在有一个通道可以在我们想要的时候停止任务。虽然您的实现允许您通过该方法停止任务Stop()，但 goroutine 将保持打开状态，因为通道永远不会关闭（因此会泄漏内存）。// Includes a channel to stop the task if needed.quit := make(chan bool, 1)go func() {&nbsp; &nbsp; task()&nbsp; &nbsp; for {&nbsp; &nbsp; &nbsp; &nbsp; select {&nbsp; &nbsp; &nbsp; &nbsp; case <-quit:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return&nbsp; &nbsp; &nbsp; &nbsp; case <-time.After(5 * time.Second):&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; task()&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; }}()// To stop the taskquit <- true这是三个解决方案中最强大的解决方案。任务可以随时停止，并且它还会考虑任务在等待再次运行时所花费的时间。在前面的示例中，如果任务运行时间为 1 秒，而您又等待 5 秒，则相对于任务启动时的时间间隔实际上是 6 秒。该解决方案实际上仅适用于运行时间非常长的任务，或者如果您的任务以恒定的时间间隔运行至关重要。如果任务必须以恒定的时间间隔运行，那么您需要考虑到time.After()至少会等待您提供的持续时间的事实——如果 CPU 忙于其他进程/goroutines，它最终可能会等待稍长的时间。// Calls `fn` and then waits so the total elapsed time is `interval`func runAndWait(interval time.Duration, fn func()) {&nbsp; &nbsp; earlier := time.Now()&nbsp; &nbsp; fn()&nbsp; &nbsp; diff := time.Now().Sub(earlier)&nbsp; &nbsp; <-time.After(interval - diff)}quit := make(chan bool, 1)go func() {&nbsp; &nbsp; // The total time to run one iteration of the task&nbsp; &nbsp; interval := 5 * time.Second&nbsp; &nbsp; for {&nbsp; &nbsp; &nbsp; &nbsp; select {&nbsp; &nbsp; &nbsp; &nbsp; case <-quit:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return&nbsp; &nbsp; &nbsp; &nbsp; default:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; runAndWait(interval, task)&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; }}()