返回介绍

gocron

发布于 2023-06-25 22:01:52 字数 2178 浏览 0 评论 0 收藏 0

1.1.1. jasonlvhit/gocron

安装:

go get -u github.com/jasonlvhit/gocron

每隔1秒执行一个任务,每隔4秒执行另一个任务:

package main

import (
    "fmt"
    "time"

    "github.com/jasonlvhit/gocron"
)

func task() {
    fmt.Println("I am runnning task.", time.Now())
}
func superWang() {
    fmt.Println("I am runnning superWang.", time.Now())
}

func main() {
    s := gocron.NewScheduler()
    s.Every(1).Seconds().Do(task)
    s.Every(4).Seconds().Do(superWang)

    sc := s.Start() // keep the channel
    go test(s, sc)  // wait
    <-sc            // it will happens if the channel is closed
}

func test(s *gocron.Scheduler, sc chan bool) {
    time.Sleep(8 * time.Second)
    s.Remove(task) //remove task
    time.Sleep(8 * time.Second)
    s.Clear()
    fmt.Println("All task removed")
    close(sc) // close the channel
}

输出结果:

    I am runnning task. 2019-11-15 09:37:07.218128145 +0800 CST m=+1.000414542
    I am runnning task. 2019-11-15 09:37:08.218062127 +0800 CST m=+2.000348513
    I am runnning task. 2019-11-15 09:37:09.218047138 +0800 CST m=+3.000333512
    I am runnning superWang. 2019-11-15 09:37:10.218058701 +0800 CST m=+4.000345070
    I am runnning task. 2019-11-15 09:37:10.218100706 +0800 CST m=+4.000387079
    I am runnning task. 2019-11-15 09:37:11.218033085 +0800 CST m=+5.000319455
    I am runnning task. 2019-11-15 09:37:12.21804561 +0800 CST m=+6.000331978
    I am runnning task. 2019-11-15 09:37:13.218053083 +0800 CST m=+7.000339456
    I am runnning superWang. 2019-11-15 09:37:14.218038711 +0800 CST m=+8.000325086
    I am runnning superWang. 2019-11-15 09:37:18.218061128 +0800 CST m=+12.000347516
    I am runnning superWang. 2019-11-15 09:37:22.218054256 +0800 CST m=+16.000340629
    All task removed

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
    原文