diff --git a/cmd/main.go b/cmd/main.go index ca70092..9fd209c 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -30,7 +30,7 @@ func main() { func worker() { client := getRedis() - w := timerx.InitOnce(context.Background(), client, &Worker{}) + w := timerx.InitOnce(context.Background(), client,"test", &Worker{}) w.Add("test", "test", 1*time.Second, map[string]interface{}{ "test": "test", }) @@ -52,7 +52,7 @@ func worker() { type Worker struct{} -func (w *Worker) Worker(uniqueKey string, jobType string, data interface{}) (timerx.WorkerCode, time.Duration) { +func (w *Worker) Worker(jobType string,uniqueKey string, data interface{}) (timerx.WorkerCode, time.Duration) { fmt.Println("执行时间:", time.Now().Format("2006-01-02 15:04:05")) fmt.Println(uniqueKey, jobType) fmt.Println(data) diff --git a/once.go b/once.go index f498b94..cfbaa25 100644 --- a/once.go +++ b/once.go @@ -14,9 +14,9 @@ import ( ) // 功能描述 -// 1. 任务全局唯一 -// 2. 任务只执行一次 -// 3. 任务执行失败可以重新放入队列 +// 1. 任务可以多节点发布 +// 2. 每个任务的执行在全局仅会执行一次 +// 3. 任务执行失败支持快捷重新加入队列 // 单次的任务队列 type worker struct { diff --git a/single.go b/single.go index e73fa2e..a309a28 100644 --- a/single.go +++ b/single.go @@ -13,8 +13,7 @@ import ( ) // 定时器 -// 原理:每毫秒的时间触发 -// 单机版重复时间间隔定时器 +// 1. 这个定时器的作用范围是本机 // uuid -> timerStr var timerMap = make(map[string]*timerStr)