分布式幂等性判断

yzg-util-redis/src/main/java/com.yanzuoguang.redis/CacheLock.java

@@ -38,7 +38,24 @@ public class CacheLock implements Runnable {
     /**
      * 执行函数
      */
-    private final Runnable func;
+    private Runnable func;
+
+    /**
+     * 等待次数
+     */
+    private int waitCount;
+
+    /**
+     * 构造函数
+     *
+     * @param cache
+     * @param lockTime
+     * @param waitUnitTime
+     * @param key
+     */
+    public CacheLock(Cache cache, int lockTime, int waitUnitTime, String key) {
+        this(cache, lockTime, waitUnitTime, key, null);
+    }
 
     /**
      * 构造函数
@@ -57,11 +74,31 @@ public class CacheLock implements Runnable {
         this.func = func;
     }
 
+    /**
+     * 等待次数
+     *
+     * @return
+     */
+    public int getWaitCount() {
+        return waitCount;
+    }
+
+    /**
+     * 开始执行，每个关键字会等待其他关键字执行完成后执行
+     */
+    public void run(Runnable func) {
+        this.func = func;
+        this.run();
+    }
+
     /**
      * 开始执行，每个关键字会等待其他关键字执行完成后执行
      */
     @Override
     public void run() {
+        if (this.func == null) {
+            return;
+        }
         // 需要运行的函数
         Runnable runnable = new Runnable() {
             @Override
@@ -76,6 +113,7 @@ public class CacheLock implements Runnable {
             cache.tryLockAndRun(key, lockTime, TimeUnit.SECONDS, runnable);
             // 假如没有运行，则等待50毫秒后继续运行
             if (!runFlag) {
+                this.waitCount++;
                 ThreadHelper.sleep(waitUnitTime);
             }
         } while (!runFlag);