1. gocron

1.1.1. jasonlvhit/gocron

安装：

  1. go get -u github.com/jasonlvhit/gocron

每隔1秒执行一个任务，每隔4秒执行另一个任务：

  1. package main
  3. import (
  4.     "fmt"
  5.     "time"
  7.     "github.com/jasonlvhit/gocron"
  8. )
  10. func task() {
  11.     fmt.Println("I am runnning task.", time.Now())
  12. }
  13. func superWang() {
  14.     fmt.Println("I am runnning superWang.", time.Now())
  15. }
  17. func main() {
  18.     s := gocron.NewScheduler()
  19.     s.Every(1).Seconds().Do(task)
  20.     s.Every(4).Seconds().Do(superWang)
  22.     sc := s.Start() // keep the channel
  23.     go test(s, sc)  // wait
  24.     <-sc            // it will happens if the channel is closed
  25. }
  27. func test(s *gocron.Scheduler, sc chan bool) {
  28.     time.Sleep(8 * time.Second)
  29.     s.Remove(task) //remove task
  30.     time.Sleep(8 * time.Second)
  31.     s.Clear()
  32.     fmt.Println("All task removed")
  33.     close(sc) // close the channel
  34. }

输出结果：

  1.     I am runnning task. 2019-11-15 09:37:07.218128145 +0800 CST m=+1.000414542
  2.     I am runnning task. 2019-11-15 09:37:08.218062127 +0800 CST m=+2.000348513
  3.     I am runnning task. 2019-11-15 09:37:09.218047138 +0800 CST m=+3.000333512
  4.     I am runnning superWang. 2019-11-15 09:37:10.218058701 +0800 CST m=+4.000345070
  5.     I am runnning task. 2019-11-15 09:37:10.218100706 +0800 CST m=+4.000387079
  6.     I am runnning task. 2019-11-15 09:37:11.218033085 +0800 CST m=+5.000319455
  7.     I am runnning task. 2019-11-15 09:37:12.21804561 +0800 CST m=+6.000331978
  8.     I am runnning task. 2019-11-15 09:37:13.218053083 +0800 CST m=+7.000339456
  9.     I am runnning superWang. 2019-11-15 09:37:14.218038711 +0800 CST m=+8.000325086
  10.     I am runnning superWang. 2019-11-15 09:37:18.218061128 +0800 CST m=+12.000347516
  11.     I am runnning superWang. 2019-11-15 09:37:22.218054256 +0800 CST m=+16.000340629
  12.     All task removed