解决栈溢出问题

foldright · Jun 26, 2024 · e8ce48b · e8ce48b
1 parent a68fb69
commit e8ce48b
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/cffu-core/src/main/java/io/foldright/cffu/Cffu.java b/cffu-core/src/main/java/io/foldright/cffu/Cffu.java
@@ -227,7 +227,7 @@ public Cffu<Void> thenRunAsync(Runnable action, Executor executor) {
      */
     public <T, U> Cffu<List<U>> thenMApplyFastFailAsync(
             CompletionStage<? extends T> cf, Function<? super T, ? extends U>... fns) {
-        return thenMApplyFastFailAsync(cf, fns);
+        return thenMApplyFastFailAsync(cf,fac.defaultExecutor(),fns);
     }
 
     /**
@@ -270,7 +270,7 @@ public <T, U> Cffu<List<U>> thenMApplyFastFailAsync(
     public <T, U> Cffu<List<U>> thenMApplyMostSuccessAsync(
             CompletionStage<? extends T> cf, @Nullable U valueIfNotSuccess,
             long timeout, TimeUnit unit, Function<? super T, ? extends U>... fns) {
-        return thenMApplyMostSuccessAsync(cf, valueIfNotSuccess, timeout, unit, fns);
+        return thenMApplyMostSuccessAsync(cf, valueIfNotSuccess, fac.defaultExecutor(),timeout, unit, fns);
     }
 
     /**
@@ -310,7 +310,7 @@ public <T, U> Cffu<List<U>> thenMApplyMostSuccessAsync(
      */
     public <T, U> Cffu<List<U>> thenMApplyAsync(
             CompletionStage<? extends T> cf, Function<? super T, ? extends U>... fns) {
-        return thenMApplyAsync(cf, fns);
+        return thenMApplyAsync(cf,fac.defaultExecutor(), fns);
     }
 
     /**
@@ -339,7 +339,7 @@ public <T, U> Cffu<List<U>> thenMApplyAsync(
      */
     public <T> Cffu<Void> thenMAcceptAsync(
             CompletionStage<? extends T> cf, Consumer<? super T>... actions) {
-        return thenMAcceptAsync(cf, actions);
+        return thenMAcceptAsync(cf,fac.defaultExecutor(), actions);
     }
 
     /**
@@ -367,7 +367,7 @@ public <T> Cffu<Void> thenMAcceptAsync(
      */
     public <T> Cffu<Void> thenMAcceptFastFailAsync(
             CompletionStage<? extends T> cf, Consumer<? super T>... actions) {
-        return thenMAcceptFastFailAsync(cf, actions);
+        return thenMAcceptFastFailAsync(cf,fac.defaultExecutor(), actions);
     }
 
     /**
@@ -398,7 +398,7 @@ public <T> Cffu<Void> thenMAcceptFastFailAsync(
      * @see CompletableFuture#thenRunAsync(Runnable)
      */
     public Cffu<Void> thenMRunFastFailAsync(CompletionStage<?> cf, Runnable... actions) {
-        return thenMRunFastFailAsync(cf, actions);
+        return thenMRunFastFailAsync(cf,fac.defaultExecutor(), actions);
     }
 
     /**
@@ -426,7 +426,7 @@ public Cffu<Void> thenMRunFastFailAsync(
      * @see CompletableFuture#thenRunAsync(Runnable)
      */
     public Cffu<Void> thenMRunAsync(CompletionStage<?> cf, Runnable... actions) {
-        return thenMRunAsync(cf, actions);
+        return thenMRunAsync(cf,fac.defaultExecutor(), actions);
     }
 
     /**