Documentation ¶
Index ¶
- func DateOf(t int64) string
- func Exist(filename string) bool
- func Init(pidFile string)
- func IsSameType(a, b interface{}) bool
- func Message(msgAndArgs ...interface{}) string
- func Mkdir(name string) error
- func PWD() string
- func ParseLocalTime(strTime string) (*time.Time, error)
- func SleepFunc(duration time.Duration) func()
- func WaitFunc(checkCycle time.Duration, name string) (chan<- time.Duration, func())
- func WaitingKill() chan struct{}
- type Error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Init ¶
func Init(pidFile string)
Init 初始化的方法汇总,提供了以下功能: 1.利用CPU全部内核 2.保存当前程序pid号到pidFile文件中。关闭程序, 可在命令行使用 $ kill `cat $pidFile`
func Message ¶
func Message(msgAndArgs ...interface{}) string
Message 把msgAndArgs 格式化成消息 NOTICE: 使用方法 Message(msgAndArgs...)
func ParseLocalTime ¶
ParseLocalTime 把string格式的时间,转换成time.time NOTICE: 我写这个函数的原因是 1. 添加更详解的错误说明。 2. 编写单元测试,查看是否真的转换成功了。
func SleepFunc ¶
SleepFunc 返回一个等待sleep函数, 使程序暂停一个duration。 SleepFunc是以上WaitFunc的简化版本,通常运用于API访问限制 利用闭包,把beginTime变量包裹到了sleep函数内。
func WaitFunc ¶
WaitFunc 返回 一个 cycleCh chan<- time.Duration 和 一个 Wait 函数 如果 cycleCh <- d ,则 Wait() 的sleep时间被修改为 d sleep时间的修改会立即生效,不用等到此waitDuration结束。 例如:当100秒的waitDuration时间已过51秒时,把waitDuration修改为50秒,程序会立刻结束。
不用等到100秒才结束。
例如:100秒的waitDuration在结束前,把waitDuration修改为200秒,
此次Wait()会sleep 200秒才结束。
checkCycle是检查是否到期的时间段,也是最小等待时间段。
当checkCycle较大时,Wait()的sleep时间会和waitDuration,有较大的差距, 程序的实际等待时间,总是 checkCycle × int(waitDuration/checkCycle + 1)