diff --git a/src/main/java/org/tikv/txn/TwoPhaseCommitter.java b/src/main/java/org/tikv/txn/TwoPhaseCommitter.java
index 550b7de47ac..d602cd5261f 100644
--- 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(