go generate_golang反向代理

(22) 2024-10-03 09:01:01

Timer Tricker 代码

package main import ( "fmt" "sync" "time" ) /** *ticker只要定义完成,从此刻开始计时,不需要任何其他的操作,每隔固定时间都会触发。 *timer定时器,是到固定时间后会执行一次 *如果timer定时器要每隔间隔的时间执行,实现ticker的效果,使用 func (t *Timer) Reset(d Duration) bool */ func main() { 
    var wg sync.WaitGroup wg.Add(2) //NewTimer 创建一个 Timer,它会在最少过去时间段 d 后到期,向其自身的 C 字段发送当时的时间 timer1 := time.NewTimer(2 * time.Second) //NewTicker 返回一个新的 Ticker,该 Ticker 包含一个通道字段,并会每隔时间段 d 就向该通道发送当时的时间。它会调 //整时间间隔或者丢弃 tick 信息以适应反应慢的接收者。如果d <= 0会触发panic。关闭该 Ticker 可以释放相关资源。 ticker1 := time.NewTicker(2 * time.Second) go func(t *time.Ticker) { 
    defer wg.Done() for { 
    <-t.C fmt.Println("get ticker1", time.Now().Format("2006-01-02 15:04:05")) } }(ticker1) go func(t *time.Timer) { 
    defer wg.Done() for { 
    <-t.C fmt.Println("get timer", time.Now().Format("2006-01-02 15:04:05")) //Reset 使 t 重新开始计时,(本方法返回后再)等待时间段 d 过去后到期。如果调用时 t 还在等待中会返回真;如果 t已经到期或者被停止了会返回假。 t.Reset(2 * time.Second) } }(timer1) wg.Wait() } 

Tricker 类型包含一个channel 有时候会遇到每隔一段时间执行的业务(比如设置心跳时间等) 就可以用它来处理 这是一个重复的过程

ticker 和newTicker 区别
ticker 无法取消
newTicker 可以调用Stop() 方法删除

// 无法取消 tick := time.Tick(1 * time.Minute) for _ = range tick { 
    // do something } // 可通过调用ticker.Stop取消 ticker := time.NewTicker(1 * time.Minute) for _ = range tick { 
    // do something } 

Timer 类型 用来代表一个单独的事件, 当设置的时间结束之后发送当前时间到channel 通过两种方式创建

func AfterFunc(d Duration, f func()) *Timer // 指定一段时间后指定的函数 func NewTimer(d Duration) *Timer 

注意
以上两函数都可以使用Reset, 这个有个特别的地方是还是使用Reset 时需要确保的t.C 通道被释放时才能调用, 以防止发生资源竞争的问题。 可以通过一下方式 解决:
if !t.Stop(){

<- t.C
}
t.Reset()

拓展

https://tonybai.com/2016/12/21/how-to-use-timer-reset-in-golang-correctly/

https://blog.gopheracademy.com/advent-2016/go-timers/

THE END

发表回复