golang 定时器

浏览数：45 / 时间：2015年06月10日

代码文件timer.go：

package main

import (
	"bytes"
	"fmt"
	"github.com/unknwon/goconfig"
	"os/exec"
	"time"
)

var config *goconfig.ConfigFile

func init() {
	path := "./config.ini"
	conf, err := goconfig.LoadConfigFile(path)
	if err != nil {
		fmt.Println(err)
	}
	config = conf
}
 
func main() {
	t := time.NewTicker(1 * time.Second)
	for {
		select {
		case <-t.C:
			run()
		}
	}
}

func run() {
	startTimestamp, _ := config.Int64("time", "startTimestamp")
	loopSeconds, _ := config.Int64("time", "loopSeconds")
	unix := time.Now().Unix()
	if startTimestamp <= unix && (unix-startTimestamp)%loopSeconds == 0 {
		cmd()
	}
}

func cmd() {
	scriptBinPath, _ := config.GetValue("cmd", "scriptBinPath")
	filepath, _ := config.GetValue("cmd", "filePath")
	params, _ := config.GetValue("cmd", "params")
	cmd := exec.Command(scriptBinPath, filepath, params)
	var out bytes.Buffer
	cmd.Stdout = &out
	err := cmd.Start()
	if err != nil {
		fmt.Println(err)
	}
	fmt.Println("Waiting for command to finish...")
	err = cmd.Wait()
	if err != nil {
		fmt.Printf("Command finished with error: %v", err)
	}
	fmt.Println(out.String())
}

配置文件config.ini放在代码生成可执行文件同级目录

[time]
;开始的时间戳
startTimestamp:1396361928
;循环的时间间隔
loopSeconds:3
[cmd]
;执行的脚本
scriptBinPath:E:/zendloader+redis+iis/php-5.3.28-nts-Win32-VC9-x86/php.exe
;被执行的文件
filePath:D:/jianguo/command/application/command/demo.php
;参数
params:

本文来自：开源中国博客

感谢作者：chen yuwen

查看原文：golang 定时器

郑重声明：本站内容如果来自互联网及其他传播媒体，其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。

golang 定时器