一、前言
1、go有现成的周期定时器和定时器,但是没有定时周期
2、基于在未来某个时刻后进行周期循环,于是有了定时周期
3、本文秒级精度的定时器,存在几个指令时间的误差
二、实现
1、基础代码
package timer
import (
"time"
)
//阻塞循环定时器
func tickerDone(interval int, function func()) {
eventsTick := time.NewTicker(time.Duration(interval) * time.Second)
defer eventsTick.Stop()
for {
select {
case <-eventsTick.C:
function()
}
}
}
//阻塞定时器
func timerDone(interval int, function func()) {
eventsTick := time.NewTimer(time.Duration(interval) * time.Second)
defer eventsTick.Stop()
<-eventsTick.C
function()
}
2、周期定时器
方式一:
const (
Simple_time_timeTemplate = "2006-01-02 15:04:05"
)
//指定时间定时循环
//intput:timePeriod 时间周期 单位秒
//intput:startTime 定时开始时间
//intput:timeTemplate 时间格式模板
//intput: callfunc 回调函数
func Ticker1(timePeriod int, startTime, timeTemplate string, callFunc func()) error {
if timeTemplate == "" {
timeTemplate = Simple_time_timeTemplate
}
startTimeStamp, err := time.ParseInLocation(timeTemplate, startTime, time.Local)
if err != nil {
return err
}
if timePeriod <= 0 {
return err
}
go func() {
nowTimeStamp := time.Now()
interval := startTimeStamp.Second() - (nowTimeStamp.Second())
if interval < 0 {
interval = timePeriod + interval%timePeriod
}
time.Sleep(time.Duration(interval) * time.Second)
tickerDone(timePeriod, func() {
callFunc()
})
}()
return nil
}
方式二:
//指定时间定时循环
//intput:timePeriod 时间周期
//intput:startTime 定时开始时间
//intput:timeTemplate 时间格式模板
//intput: callfunc 回调函数
func Ticker2(timePeriod int, startTime, timeTemplate string, callFunc func()) error {
if timeTemplate == "" {
timeTemplate = Simple_time_timeTemplate
}
startTimeStamp, err := time.ParseInLocation(timeTemplate, startTime, time.Local)
if err != nil {
return err
}
if timePeriod <= 0 {
return err
}
go func() {
nowTimeStamp := time.Now()
interval := startTimeStamp.Second() - nowTimeStamp.Second()
if interval < 0 {
interval = timePeriod + interval%timePeriod
}
if interval != 0 {
timerDone(interval, callFunc)
}
tickerDone(timePeriod, callFunc)
}()
return nil
}
三、单元测试
package timer
import (
"fmt"
"testing"
"time"
)
func TestTicker1(t *testing.T) {
//从2019-09-17 19:14:30起 每1秒调用方法
Ticker1(1, "2019-09-17 19:14:30", Simple_time_timeTemplate, func() {
fmt.Println("Hello", time.Now())
})
select {}
}
func TestTicker2(t *testing.T) {
//从2019-09-17 19:14:30起 每1秒调用方法
Ticker2(1, "2019-10-20 10:00:00", Simple_time_timeTemplate, func() {
fmt.Println("Hello", time.Now())
})
select {}
}
func TestTimerDo(t *testing.T) {
timerDone(20, func() {
fmt.Println("Hello", time.Now())
})
}
func TestTickerDo(t *testing.T) {
tickerDone(20, func() {
fmt.Println("Hello", time.Now())
})
}