Merge branch 'master' into hotfix/officialbugfix

tikv · Jun 4, 2024 · bc40a34 · bc40a34
2 parents 6757dce + 700fad0
commit bc40a34
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/main/java/org/tikv/txn/TwoPhaseCommitter.java b/src/main/java/org/tikv/txn/TwoPhaseCommitter.java
@@ -88,6 +88,11 @@ public TwoPhaseCommitter(TiSession session, long startTime) {
   }
 
   public TwoPhaseCommitter(TiSession session, long startTime, long lockTTL) {
+    this(session, startTime, lockTTL, createExecutorService(WRITE_BUFFER_SIZE));
+  }
+
+  public TwoPhaseCommitter(
+      TiSession session, long startTime, long lockTTL, ExecutorService executorService) {
     this(
         session,
         startTime,
@@ -98,7 +103,7 @@ public TwoPhaseCommitter(TiSession session, long startTime, long lockTTL) {
         1,
         true,
         3,
-        createExecutorService(WRITE_BUFFER_SIZE));
+        executorService);
   }
 
   TwoPhaseCommitter(