add TwoPhaseCommitter new Constructor contains executorService(#774)

tikv · Jan 18, 2024 · 5d22be4 · 5d22be4
1 parent 533dbc2
commit 5d22be4
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/src/main/java/org/tikv/txn/TwoPhaseCommitter.java b/src/main/java/org/tikv/txn/TwoPhaseCommitter.java
@@ -101,6 +101,21 @@ public TwoPhaseCommitter(TiSession session, long startTime, long lockTTL) {
         createExecutorService(WRITE_BUFFER_SIZE));
   }
 
+  public TwoPhaseCommitter(
+      TiSession session, long startTime, long lockTTL, ExecutorService executorService) {
+    this(
+        session,
+        startTime,
+        lockTTL,
+        TXN_COMMIT_BATCH_SIZE,
+        TXN_COMMIT_BATCH_SIZE,
+        WRITE_BUFFER_SIZE,
+        1,
+        true,
+        3,
+        executorService);
+  }
+
   TwoPhaseCommitter(
       TiSession session,
       long startTime,