zoukankan      html  css  js  c++  java
  • log4go的精确定时程序(带自动延迟补偿)

    程序设计目标是在程序启动10秒后执行某个任务,例如日志转储(rotate),以后每隔15秒执行一次。

    初次的设计

    package main
    
    import (
    	"time"
    	"fmt"
    )
    
    func main() {
    	timer := time.NewTimer(10 * time.Second)
    	fmt.Println(time.Now())
     	for {
    		select {
    		case <-timer.C:
    			fmt.Println(time.Now())
    			time.Sleep(1 * time.Second)
    			timer.Reset(15 * time.Second)
    		}
    	}
    }
    

    显然,在设置下一个定时(timer.Reset(15 * time.Second))之前,多少都会消耗一点时间,即使是毫秒级的延迟,也一定会产生累计误差。
    为了使问题更明显,在程序中增加了一秒的 Sleep。测试结果如下:

    2017-07-18 23:16:24.791623 +0800 CST
    2017-07-18 23:16:34.7917567 +0800 CST
    2017-07-18 23:16:50.7920782 +0800 CST
    2017-07-18 23:17:06.7929373 +0800 CST
    2017-07-18 23:17:22.7944063 +0800 CST
    2017-07-18 23:17:38.7951302 +0800 CST
    2017-07-18 23:17:54.7968096 +0800 CST
    2017-07-18 23:18:10.7985468 +0800 CST
    2017-07-18 23:18:26.7993588 +0800 CST
    2017-07-18 23:18:42.7996568 +0800 CST
    2017-07-18 23:18:58.8008621 +0800 CST
    

    改进后的程序

    package main
    
    import (
    	"time"
    	"fmt"
    )
    
    func main() {
    	next := time.Now().Add(10 * time.Second)
    	timer := time.NewTimer(next.Sub(time.Now()))
    	fmt.Println(time.Now())
     	for {
    		select {
    		case <-timer.C:
    			fmt.Println(time.Now())
    			time.Sleep(1 * time.Second)
    			next = next.Add(15 * time.Second)
    			timer.Reset(next.Sub(time.Now()))
    		}
    	}
    }
    

    简单说就是增加了一个时间变量 next,在设置定时器之前,通过计算获得下一次任务的执行时间。
    而定时器用 next - Now() 来设置。测试结果如下:

    2017-07-18 23:16:20.2456695 +0800 CST
    2017-07-18 23:16:30.2466397 +0800 CST
    2017-07-18 23:16:45.2457191 +0800 CST
    2017-07-18 23:17:00.2458328 +0800 CST
    2017-07-18 23:17:15.2451861 +0800 CST
    2017-07-18 23:17:30.2452624 +0800 CST
    2017-07-18 23:17:45.2468138 +0800 CST
    2017-07-18 23:18:00.245947 +0800 CST
    

    从以上结果看,精度可控制在 ± 2ms。完全可以满足定时转储日志文件的需要。

  • 相关阅读:
    RDD模型
    python代码实现自动化测试中字符串自动生成
    windows7下python2.6 + mysql5.5(No module named MySQLdb/DLL load failed/from sets import ImmutableSet)
    python import的用法
    linux命令后台运行
    jenkins插件库打开报错There were errors checking the update sites
    python虚拟环境pipenv的安装和使用
    微信支付v3 php回调函数 TP5 签名/验签/下载证书
    hive/spark的RoaringBitmap写入Clickhouse的bitmap
    收集与测试有关的网站
  • 原文地址:https://www.cnblogs.com/ccpaging/p/7203431.html
Copyright © 2011-2022 走看看