From 43d2798b41ad8ab2ab46da7d5cc6c4345ff01f49 Mon Sep 17 00:00:00 2001
From: Yun <yun@yun.ink>
Date: Wed, 27 Dec 2023 17:19:52 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=AE=9A=E6=97=B6=E5=99=A8?=
 =?UTF-8?q?=E7=9A=84=E8=A1=A8=E8=BF=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cmd/main.go | 4 ++--
 once.go     | 6 +++---
 single.go   | 3 +--
 3 files changed, 6 insertions(+), 7 deletions(-)

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)