reset threshold park when destory

ctripcorp · Nov 21, 2023 · 70cba87 · 70cba87
1 parent 2f9b9f4
commit 70cba87
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 0 deletions.
diff --git a/...rc/main/java/com/ctrip/xpipe/redis/keeper/applier/sequence/DefaultSequenceController.java b/...rc/main/java/com/ctrip/xpipe/redis/keeper/applier/sequence/DefaultSequenceController.java
@@ -93,6 +93,8 @@ protected void doDispose() throws Exception {
         super.doDispose();
         closeState.setClosed();
         runningCommands.clear();
+        memoryThreshold.reset();
+        concurrencyThreshold.reset();
     }
 
     @Override

diff --git a/...er/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/ConcurrencyThreshold.java b/...er/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/ConcurrencyThreshold.java
@@ -19,4 +19,8 @@ public void release() {
         super.release(1);
     }
 
+    @Override
+    public void reset() {
+        super.reset();
+    }
 }
diff --git a/...-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/MemoryThreshold.java b/...-keeper/src/main/java/com/ctrip/xpipe/redis/keeper/applier/threshold/MemoryThreshold.java
@@ -20,4 +20,9 @@ public void tryPass(long bytes) {
     public void release(long bytes) {
         super.release(bytes);
     }
+
+    @Override
+    public void reset() {
+        super.reset();
+    }
 }