当前位置:主页 > 查看内容

Ticker Or Sleep?定时执行的新选择

发布时间:2021-09-06 00:00| 位朋友查看

简介:在写 Python 的时候,如果想让某个函数每 60 秒执行一次,我们一般这样写代码: importtime whileTrue: some_function() time.sleep(60) 于是,我在写 Golang 代码的时候,也使用了这种方式: packagemain import( fmt time ) funcsomeFunction(){ fmt.Print……

在写 Python 的时候,如果想让某个函数每 60 秒执行一次,我们一般这样写代码:

  1. import time 
  2.  
  3. while True: 
  4.     some_function() 
  5.     time.sleep(60) 

于是,我在写 Golang 代码的时候,也使用了这种方式:

  1. package main 
  2.  
  3. import ( 
  4.     "fmt" 
  5.     "time" 
  6.  
  7. func someFunction() { 
  8.     fmt.Println("我是某个函数") 
  9.  
  10. func main() { 
  11.     for { 
  12.         someFunction() 
  13.         time.Sleep(10 * time.Second) 
  14.     } 

今天在看同事的代码时,发现他是这样写的:

  1. package main 
  2.  
  3. import ( 
  4.     "fmt" 
  5.     "time" 
  6.  
  7. func someFunction() { 
  8.     fmt.Println("我是某个函数") 
  9.  
  10. func main() { 
  11.     tikcer :time.NewTicker(10 * time.Second) 
  12.     for { 
  13.         <-tikcer.C 
  14.         someFunction() 
  15.     } 

这种写法,初看起来时跟time.Sleep没什么区别,但是仔细一想,却发现它有很多优势。

首先,NewTicker会在背后计时,时间到了以后,会向内部的一个 channel 中推入当前的时间。然后继续计时。所以,如果函数someFunction()执行了3秒钟。那么接下来过7秒就会继续执行。但如果使用time.Sleep,函数执行完成以后,还要再等10秒钟才会执行。

其次,如果不启动新的协程,那么当执行到time.Sleep时,整个程序是卡住的,必须等待它结束了才能执行后面的操作。但如果使用 NewTicker,那么在等待的时间,还可以做很多其他的事情。多个不同的定时器可以同时工作:

  1. package main 
  2.  
  3. import ( 
  4.     "fmt" 
  5.     "time" 
  6.  
  7. func someFunction() { 
  8.     fmt.Println("我是某个函数") 
  9.  
  10. func anotherFunction() { 
  11.     fmt.Println("另一个函数") 
  12.  
  13. func thirdFunction() { 
  14.     fmt.Println("第三个函数") 
  15.  
  16. func main() { 
  17.     tikcer1 :time.NewTicker(10 * time.Second) 
  18.     tikcer2 :time.NewTicker(5 * time.Second) 
  19.     tikcer3 :time.NewTicker(3 * time.Second) 
  20.     for { 
  21.         select { 
  22.         case <-tikcer1.C: 
  23.             someFunction() 
  24.         case <-tikcer2.C: 
  25.             anotherFunction() 
  26.         case <-tikcer3.C: 
  27.             thirdFunction() 
  28.         } 
  29.     } 

这样可以实现,每3秒执行 thirdFunction函数,每5秒执行anotherFunction,每10秒执行一次someFunction。大家可以考虑一下,如何用 time.Sleep来实现这样的功能。

注意每个函数都是独立计时的,只要他们执行的时间不超过他们间隔的时间,就不会互相影响。

除了全部用来计时外,我们还可以用来设置外部开关,中断一个协程。例如:

  1. package main 
  2.  
  3. import ( 
  4.     "fmt" 
  5.     "time" 
  6.  
  7. func doSomething() { 
  8.     fmt.Println("进行某些操作") 
  9.  
  10. func someFunction(stop chan bool) { 
  11.     fmt.Println("我是某个函数") 
  12.     tikcer1 :time.NewTicker(10 * time.Second) 
  13.     for { 
  14.         select { 
  15.         case <-tikcer1.C: 
  16.             doSomething() 
  17.         case <-stop: 
  18.             return 
  19.         } 
  20.     } 
  21.  
  22. func main() { 
  23.     stop :make(chan bool) 
  24.     go someFunction(stop) 
  25.     //很多行代码 
  26.     //很多行代码 
  27.     //很多行代码 
  28.     stop <- true 
  29.     //其他代码 
  30.     //其他代码 

在协程里面是一个10秒执行一次的定时函数。但是我们可以在外面控制这个协程,从而随时停止这个协程。

本文转载自微信公众号「未闻Code」,可以通过以下二维码关注。转载本文请联系未闻Code公众号。


本文转载自网络,原文链接:http://mp.weixin.qq.com/s?__biz=MzI2MzEwNTY3OQ==&mid=2648979689&idx=1&sn=82784d062ebf18413d5ab6db5a1f50ff&chksm=f2506509c527ec1fdf68faa3bf61a8d39bfb3688e34c5ee0c1ca0931eba7687f24846957516d&mpshare=1&s
本站部分内容转载于网络,版权归原作者所有,转载之目的在于传播更多优秀技术内容,如有侵权请联系QQ/微信:153890879删除,谢谢!

推荐图文


随机推荐