參考文章：http://beego.top/example/toolbox.html#task

beego里的toolbox.StartTask()是有協(xié)程go出去，所以需要加個(gè)協(xié)程鎖，保證子協(xié)程能執(zhí)行完。

package main

import (
    "sync"
    "time"

    "github.com/astaxie/beego/logs"
    "github.com/astaxie/beego/toolbox"
)

var TimerWg sync.WaitGroup

func generateWarning() error {
    defer TimerWg.Done()
    logs.Error("hello time:%v", time.Now())
    return nil
}

func main() {
    TimerWg = sync.WaitGroup{}
    TimerWg.Add(1)
    logs.Debug("start :%v", time.Now())
    tk := toolbox.NewTask("generateWarning", "0 59 17 * * *", generateWarning)
    toolbox.AddTask("generateWarning", tk)
    toolbox.StartTask()
    logs.Debug("StartTask :%v", time.Now())
    defer toolbox.StopTask()
    TimerWg.Wait()
    logs.Debug("Wait :%v", time.Now())

}

輸出：

ev@dev-VirtualBox test (master) $ go run beegotest/test_toolbox.go 
2020/09/28 17:58:22.945 [D]  start :2020-09-28 17:58:22.945124454 +0800 CST m=+0.000350274
2020/09/28 17:58:22.945 [D]  StartTask :2020-09-28 17:58:22.945457098 +0800 CST m=+0.000682916
2020/09/28 17:59:00.001 [E]  hello time:2020-09-28 17:59:00.001469156 +0800 CST m=+37.056695119
2020/09/28 17:59:00.001 [D]  Wait :2020-09-28 17:59:00.001670887 +0800 CST m=+37.056896833