diff --git a/single.go b/single.go index de079e9..638dc02 100644 --- a/single.go +++ b/single.go @@ -21,13 +21,11 @@ var timerMapMux sync.Mutex var timerCount int // 当前定时数目 var onceLimit sync.Once // 实现单例 -var nextTime = time.Now() // 下一次执行的时间 -type ContextValueKey string // 定义context 传递的Key类型 -const ( - extendParamKey ContextValueKey = "extend_param" -) + + + type single struct{} @@ -182,9 +180,6 @@ func (s *single) iteratorTimer(ctx context.Context, nowTime time.Time) { // fmt.Println("timer: one finish") } -// 定义各个回调函数 -type callback func(ctx context.Context) bool - // 定时器操作类 // 这里不应painc func (s *single) timerAction(ctx context.Context, call callback, uniqueKey string, extend ExtendParams) bool { diff --git a/types.go b/types.go index 2941402..60a186f 100644 --- a/types.go +++ b/types.go @@ -1,6 +1,9 @@ package timer -import "time" +import ( + "context" + "time" +) type timerStr struct { Callback callback // 需要回调的方法 @@ -16,3 +19,12 @@ type timerStr struct { type ExtendParams struct { Params map[string]interface{} // 带出去的参数 } +var nextTime = time.Now() // 下一次执行的时间 + +type ContextValueKey string // 定义context 传递的Key类型 +const ( + extendParamKey ContextValueKey = "extend_param" +) + +// 定义各个回调函数 +type callback func(ctx context.Context) bool