如何在Golang中使用Tickers?


经常会有这样的情况:我们希望在特定时间间隔后重复执行特定任务。在Golang中,我们可以借助**Tickers**来实现这一点。

我们也可以将它们与**goroutines**一起使用,以便在应用程序的后台运行这些任务,而不会中断应用程序的流程。

我们在Tickers中使用的函数是**NewTicker()**函数,它接受**时间**作为参数,我们可以为其提供**秒**甚至**毫秒**。

示例1

以下示例演示了如何在Golang中使用**Ticker**。请考虑以下代码。

package main

import (
   "fmt"
   "time"
)

func main() {
   fmt.Println("Starting the ticker")

   ticker := time.NewTicker(1 * time.Second)

   for _ = range ticker.C {
      fmt.Println("Ticking..")
   }
}

输出

如果我们使用命令**go run main.go**运行上述代码,我们将得到以下输出。

Starting the ticker
Ticking..
Ticking..

需要注意的是,除非我们强制停止,否则上述程序将一直执行。我们可以使用**CTRL+C**停止它。

示例2

我们还可以借助**goroutines**在后台运行Ticker。请考虑以下代码。

package main

import (
   "fmt"
   "time"
)

func inBackground() {
   ticker := time.NewTicker(1 * time.Second)

   for _ = range ticker.C {
      fmt.Println("Ticking..")
   }
}

func main() {
   fmt.Println("Starting the ticker")
   go inBackground()
   fmt.Println("After goroutine..")
   select {}
}

输出

如果我们使用命令**go run main.go**运行上述代码,我们将得到以下输出。

Starting the ticker
After goroutine..
Ticking..
Ticking..

需要注意的是,除非我们强制停止,否则上述程序将一直执行。我们可以使用**CTRL+C**停止它。

示例3

现在让我们考虑Ticker的一个更高级的用例,在这个用例中,我们将使用一个通道和一个select语句,并且Ticker也将运行一段时间。

请考虑以下代码。

package main

import (
   "fmt"
   "time"
)

func main() {
   ticker := time.NewTicker(400 * time.Millisecond)
   done := make(chan bool)
   fmt.Println("Started!")
   go func() {
      for {
         select {
         case <-done:
            return
         case t := <-ticker.C:
            fmt.Println("Tick at", t)
         }
      }
   }()
   time.Sleep(1600 * time.Millisecond)
   ticker.Stop()
   done <- true
   fmt.Println("Stopped!")
}

输出

如果我们使用命令**go run main.go**运行上述代码,我们将得到以下输出。

Started!
Tick at 2009-11-10 23:00:00.4 +0000 UTC m=+0.400000001
Tick at 2009-11-10 23:00:00.8 +0000 UTC m=+0.800000001
Tick at 2009-11-10 23:00:01.2 +0000 UTC m=+1.200000001
Tick at 2009-11-10 23:00:01.6 +0000 UTC m=+1.600000001
Stopped!

更新于: 2021年11月1日

7K+ 次浏览

启动你的职业生涯

完成课程获得认证

开始学习
广告