From f3f809af29ed9aa084419502bda4b44eb30dec34 Mon Sep 17 00:00:00 2001
From: Jerry Lee <oldratlee@gmail.com>
Date: Sat, 22 Feb 2025 18:07:09 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20wraps=20the=20supplied=20Executor=20to?=
 =?UTF-8?q?=20`Cffu`/`CffuFactory`=20=F0=9F=A7=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/io/foldright/cffu/Cffu.java | 124 +++++++++---------
 .../java/io/foldright/cffu/CffuFactory.java   |  76 ++++++-----
 .../io/foldright/cffu/CffuFactoryBuilder.java |   5 +-
 .../io/foldright/cffu/CffuFactoryTest.java    |   2 -
 4 files changed, 107 insertions(+), 100 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
index 829869cb..b98a5e4a 100644
--- a/cffu-core/src/main/java/io/foldright/cffu/Cffu.java
+++ b/cffu-core/src/main/java/io/foldright/cffu/Cffu.java
@@ -15,6 +15,8 @@
 import java.util.concurrent.*;
 import java.util.function.*;
 
+import static io.foldright.cffu.CffuFactoryBuilder.cffuScreenedExecutor;
+import static io.foldright.cffu.CffuFactoryBuilder.cffuUnscreenedExecutor;
 import static java.util.Objects.requireNonNull;
 
 
@@ -118,7 +120,7 @@ public <U> Cffu<U> thenApplyAsync(Function<? super T, ? extends U> fn) {
     @CheckReturnValue(explanation = "should use the returned Cffu; otherwise, prefer method `thenAcceptAsync`")
     @Override
     public <U> Cffu<U> thenApplyAsync(Function<? super T, ? extends U> fn, Executor executor) {
-        return resetCf(cf.thenApplyAsync(fn, executor));
+        return resetCf(cf.thenApplyAsync(fn, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -159,7 +161,7 @@ public Cffu<Void> thenAcceptAsync(Consumer<? super T> action) {
      */
     @Override
     public Cffu<Void> thenAcceptAsync(Consumer<? super T> action, Executor executor) {
-        return resetCf(cf.thenAcceptAsync(action, executor));
+        return resetCf(cf.thenAcceptAsync(action, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -197,7 +199,7 @@ public Cffu<Void> thenRunAsync(Runnable action) {
      */
     @Override
     public Cffu<Void> thenRunAsync(Runnable action, Executor executor) {
-        return resetCf(cf.thenRunAsync(action, executor));
+        return resetCf(cf.thenRunAsync(action, cffuScreenedExecutor(executor)));
     }
 
     // endregion
@@ -235,7 +237,7 @@ public final <U> Cffu<List<U>> thenMApplyFailFastAsync(Function<? super T, ? ext
      */
     @SafeVarargs
     public final <U> Cffu<List<U>> thenMApplyFailFastAsync(Executor executor, Function<? super T, ? extends U>... fns) {
-        return resetCf(CompletableFutureUtils.thenMApplyFailFastAsync(cf, executor, fns));
+        return resetCf(CompletableFutureUtils.thenMApplyFailFastAsync(cf, cffuScreenedExecutor(executor), fns));
     }
 
     /**
@@ -266,7 +268,7 @@ public final <U> Cffu<List<U>> thenMApplyAllSuccessAsync(
     @SafeVarargs
     public final <U> Cffu<List<U>> thenMApplyAllSuccessAsync(
             Executor executor, @Nullable U valueIfFailed, Function<? super T, ? extends U>... fns) {
-        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessAsync(cf, executor, valueIfFailed, fns));
+        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessAsync(cf, cffuScreenedExecutor(executor), valueIfFailed, fns));
     }
 
     /**
@@ -293,7 +295,7 @@ public final <U> Cffu<List<U>> thenMApplyMostSuccessAsync(
     public final <U> Cffu<List<U>> thenMApplyMostSuccessAsync(
             Executor executor, @Nullable U valueIfNotSuccess, long timeout, TimeUnit unit,
             Function<? super T, ? extends U>... fns) {
-        return resetCf(CompletableFutureUtils.thenMApplyMostSuccessAsync(cf, executor, valueIfNotSuccess, timeout, unit, fns));
+        return resetCf(CompletableFutureUtils.thenMApplyMostSuccessAsync(cf, cffuScreenedExecutor(executor), valueIfNotSuccess, timeout, unit, fns));
     }
 
     /**
@@ -320,7 +322,7 @@ public final <U> Cffu<List<U>> thenMApplyAsync(Function<? super T, ? extends U>.
      */
     @SafeVarargs
     public final <U> Cffu<List<U>> thenMApplyAsync(Executor executor, Function<? super T, ? extends U>... fns) {
-        return resetCf(CompletableFutureUtils.thenMApplyAsync(cf, executor, fns));
+        return resetCf(CompletableFutureUtils.thenMApplyAsync(cf, cffuScreenedExecutor(executor), fns));
     }
 
     /**
@@ -347,7 +349,7 @@ public final <U> Cffu<U> thenMApplyAnySuccessAsync(Function<? super T, ? extends
      */
     @SafeVarargs
     public final <U> Cffu<U> thenMApplyAnySuccessAsync(Executor executor, Function<? super T, ? extends U>... fns) {
-        return resetCf(CompletableFutureUtils.thenMApplyAnySuccessAsync(cf, executor, fns));
+        return resetCf(CompletableFutureUtils.thenMApplyAnySuccessAsync(cf, cffuScreenedExecutor(executor), fns));
     }
 
     /**
@@ -374,7 +376,7 @@ public final <U> Cffu<U> thenMApplyAnyAsync(Function<? super T, ? extends U>...
      */
     @SafeVarargs
     public final <U> Cffu<U> thenMApplyAnyAsync(Executor executor, Function<? super T, ? extends U>... fns) {
-        return resetCf(CompletableFutureUtils.thenMApplyAnyAsync(cf, executor, fns));
+        return resetCf(CompletableFutureUtils.thenMApplyAnyAsync(cf, cffuScreenedExecutor(executor), fns));
     }
 
     /**
@@ -406,7 +408,7 @@ public final Cffu<Void> thenMAcceptFailFastAsync(Consumer<? super T>... actions)
      */
     @SafeVarargs
     public final Cffu<Void> thenMAcceptFailFastAsync(Executor executor, Consumer<? super T>... actions) {
-        return resetCf(CompletableFutureUtils.thenMAcceptFailFastAsync(cf, executor, actions));
+        return resetCf(CompletableFutureUtils.thenMAcceptFailFastAsync(cf, cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -438,7 +440,7 @@ public final Cffu<Void> thenMAcceptAsync(Consumer<? super T>... actions) {
      */
     @SafeVarargs
     public final Cffu<Void> thenMAcceptAsync(Executor executor, Consumer<? super T>... actions) {
-        return resetCf(CompletableFutureUtils.thenMAcceptAsync(cf, executor, actions));
+        return resetCf(CompletableFutureUtils.thenMAcceptAsync(cf, cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -470,7 +472,7 @@ public final Cffu<Void> thenMAcceptAnySuccessAsync(Consumer<? super T>... action
      */
     @SafeVarargs
     public final Cffu<Void> thenMAcceptAnySuccessAsync(Executor executor, Consumer<? super T>... actions) {
-        return resetCf(CompletableFutureUtils.thenMAcceptAnySuccessAsync(cf, executor, actions));
+        return resetCf(CompletableFutureUtils.thenMAcceptAnySuccessAsync(cf, cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -502,7 +504,7 @@ public final Cffu<Void> thenMAcceptAnyAsync(Consumer<? super T>... actions) {
      */
     @SafeVarargs
     public final Cffu<Void> thenMAcceptAnyAsync(Executor executor, Consumer<? super T>... actions) {
-        return resetCf(CompletableFutureUtils.thenMAcceptAnyAsync(cf, executor, actions));
+        return resetCf(CompletableFutureUtils.thenMAcceptAnyAsync(cf, cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -522,7 +524,7 @@ public Cffu<Void> thenMRunFailFastAsync(Runnable... actions) {
      * See the {@link CffuFactory#allFailFastOf allFailFastOf} documentation for the rules of result computation.
      */
     public Cffu<Void> thenMRunFailFastAsync(Executor executor, Runnable... actions) {
-        return resetCf(CompletableFutureUtils.thenMRunFailFastAsync(cf, executor, actions));
+        return resetCf(CompletableFutureUtils.thenMRunFailFastAsync(cf, cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -542,7 +544,7 @@ public Cffu<Void> thenMRunAsync(Runnable... actions) {
      * See the {@link CffuFactory#allOf allOf} documentation for the rules of result computation.
      */
     public Cffu<Void> thenMRunAsync(Executor executor, Runnable... actions) {
-        return resetCf(CompletableFutureUtils.thenMRunAsync(cf, executor, actions));
+        return resetCf(CompletableFutureUtils.thenMRunAsync(cf, cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -562,7 +564,7 @@ public Cffu<Void> thenMRunAnySuccessAsync(Runnable... actions) {
      * See the {@link CffuFactory#anySuccessOf anySuccessOf} documentation for the rules of result computation.
      */
     public Cffu<Void> thenMRunAnySuccessAsync(Executor executor, Runnable... actions) {
-        return resetCf(CompletableFutureUtils.thenMRunAnySuccessAsync(cf, executor, actions));
+        return resetCf(CompletableFutureUtils.thenMRunAnySuccessAsync(cf, cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -582,7 +584,7 @@ public Cffu<Void> thenMRunAnyAsync(Runnable... actions) {
      * See the {@link CffuFactory#anyOf anyOf} documentation for the rules of result computation.
      */
     public Cffu<Void> thenMRunAnyAsync(Executor executor, Runnable... actions) {
-        return resetCf(CompletableFutureUtils.thenMRunAnyAsync(cf, executor, actions));
+        return resetCf(CompletableFutureUtils.thenMRunAnyAsync(cf, cffuScreenedExecutor(executor), actions));
     }
 
     // endregion
@@ -603,7 +605,7 @@ public <U1, U2> Cffu<Tuple2<U1, U2>> thenMApplyTupleFailFastAsync(
      */
     public <U1, U2> Cffu<Tuple2<U1, U2>> thenMApplyTupleFailFastAsync(
             Executor executor, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2) {
-        return resetCf(CompletableFutureUtils.thenMApplyTupleFailFastAsync(cf, executor, fn1, fn2));
+        return resetCf(CompletableFutureUtils.thenMApplyTupleFailFastAsync(cf, cffuScreenedExecutor(executor), fn1, fn2));
     }
 
     /**
@@ -621,7 +623,7 @@ public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenMApplyTupleFailFastAsync(
     public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenMApplyTupleFailFastAsync(
             Executor executor, Function<? super T, ? extends U1> fn1,
             Function<? super T, ? extends U2> fn2, Function<? super T, ? extends U3> fn3) {
-        return resetCf(CompletableFutureUtils.thenMApplyTupleFailFastAsync(cf, executor, fn1, fn2, fn3));
+        return resetCf(CompletableFutureUtils.thenMApplyTupleFailFastAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3));
     }
 
     /**
@@ -639,7 +641,7 @@ public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenMApplyTupleFailFastAsyn
     public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenMApplyTupleFailFastAsync(
             Executor executor, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4) {
-        return resetCf(CompletableFutureUtils.thenMApplyTupleFailFastAsync(cf, executor, fn1, fn2, fn3, fn4));
+        return resetCf(CompletableFutureUtils.thenMApplyTupleFailFastAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3, fn4));
     }
 
     /**
@@ -659,7 +661,7 @@ public <U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenMApplyTupleFail
             Executor executor, Function<? super T, ? extends U1> fn1,
             Function<? super T, ? extends U2> fn2, Function<? super T, ? extends U3> fn3,
             Function<? super T, ? extends U4> fn4, Function<? super T, ? extends U5> fn5) {
-        return resetCf(CompletableFutureUtils.thenMApplyTupleFailFastAsync(cf, executor, fn1, fn2, fn3, fn4, fn5));
+        return resetCf(CompletableFutureUtils.thenMApplyTupleFailFastAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3, fn4, fn5));
     }
 
     /**
@@ -681,7 +683,7 @@ public <U1, U2> Cffu<Tuple2<U1, U2>> thenMApplyAllSuccessTupleAsync(
      */
     public <U1, U2> Cffu<Tuple2<U1, U2>> thenMApplyAllSuccessTupleAsync(
             Executor executor, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2) {
-        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessTupleAsync(cf, executor, fn1, fn2));
+        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessTupleAsync(cf, cffuScreenedExecutor(executor), fn1, fn2));
     }
 
     /**
@@ -705,7 +707,7 @@ public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenMApplyAllSuccessTupleAsync(
     public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenMApplyAllSuccessTupleAsync(
             Executor executor, Function<? super T, ? extends U1> fn1,
             Function<? super T, ? extends U2> fn2, Function<? super T, ? extends U3> fn3) {
-        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessTupleAsync(cf, executor, fn1, fn2, fn3));
+        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessTupleAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3));
     }
 
     /**
@@ -729,7 +731,7 @@ public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenMApplyAllSuccessTupleAs
     public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenMApplyAllSuccessTupleAsync(
             Executor executor, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4) {
-        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessTupleAsync(cf, executor, fn1, fn2, fn3, fn4));
+        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessTupleAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3, fn4));
     }
 
     /**
@@ -755,7 +757,7 @@ public <U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenMApplyAllSucces
             Executor executor, Function<? super T, ? extends U1> fn1,
             Function<? super T, ? extends U2> fn2, Function<? super T, ? extends U3> fn3,
             Function<? super T, ? extends U4> fn4, Function<? super T, ? extends U5> fn5) {
-        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessTupleAsync(cf, executor, fn1, fn2, fn3, fn4, fn5));
+        return resetCf(CompletableFutureUtils.thenMApplyAllSuccessTupleAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3, fn4, fn5));
     }
 
     /**
@@ -780,7 +782,7 @@ public <U1, U2> Cffu<Tuple2<U1, U2>> thenMApplyMostSuccessTupleAsync(
     public <U1, U2> Cffu<Tuple2<U1, U2>> thenMApplyMostSuccessTupleAsync(
             Executor executor, long timeout, TimeUnit unit,
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2) {
-        return resetCf(CompletableFutureUtils.thenMApplyMostSuccessTupleAsync(cf, executor, timeout, unit, fn1, fn2));
+        return resetCf(CompletableFutureUtils.thenMApplyMostSuccessTupleAsync(cf, cffuScreenedExecutor(executor), timeout, unit, fn1, fn2));
     }
 
     /**
@@ -806,7 +808,7 @@ public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenMApplyMostSuccessTupleAsync(
     public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenMApplyMostSuccessTupleAsync(
             Executor executor, long timeout, TimeUnit unit, Function<? super T, ? extends U1> fn1,
             Function<? super T, ? extends U2> fn2, Function<? super T, ? extends U3> fn3) {
-        return resetCf(CompletableFutureUtils.thenMApplyMostSuccessTupleAsync(cf, executor, timeout, unit, fn1, fn2, fn3));
+        return resetCf(CompletableFutureUtils.thenMApplyMostSuccessTupleAsync(cf, cffuScreenedExecutor(executor), timeout, unit, fn1, fn2, fn3));
     }
 
     /**
@@ -834,7 +836,7 @@ public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenMApplyMostSuccessTupleA
             Executor executor, long timeout, TimeUnit unit,
             Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4) {
-        return resetCf(CompletableFutureUtils.thenMApplyMostSuccessTupleAsync(cf, executor, timeout, unit, fn1, fn2, fn3, fn4));
+        return resetCf(CompletableFutureUtils.thenMApplyMostSuccessTupleAsync(cf, cffuScreenedExecutor(executor), timeout, unit, fn1, fn2, fn3, fn4));
     }
 
     /**
@@ -863,7 +865,7 @@ public <U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenMApplyMostSucce
             Function<? super T, ? extends U2> fn2, Function<? super T, ? extends U3> fn3,
             Function<? super T, ? extends U4> fn4, Function<? super T, ? extends U5> fn5) {
         return resetCf(CompletableFutureUtils.thenMApplyMostSuccessTupleAsync(
-                cf, executor, timeout, unit, fn1, fn2, fn3, fn4, fn5));
+                cf, cffuScreenedExecutor(executor), timeout, unit, fn1, fn2, fn3, fn4, fn5));
     }
 
     /**
@@ -879,7 +881,7 @@ public <U1, U2> Cffu<Tuple2<U1, U2>> thenMApplyTupleAsync(
      */
     public <U1, U2> Cffu<Tuple2<U1, U2>> thenMApplyTupleAsync(
             Executor executor, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2) {
-        return resetCf(CompletableFutureUtils.thenMApplyTupleAsync(cf, executor, fn1, fn2));
+        return resetCf(CompletableFutureUtils.thenMApplyTupleAsync(cf, cffuScreenedExecutor(executor), fn1, fn2));
     }
 
     /**
@@ -897,7 +899,7 @@ public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenMApplyTupleAsync(
     public <U1, U2, U3> Cffu<Tuple3<U1, U2, U3>> thenMApplyTupleAsync(
             Executor executor, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3) {
-        return resetCf(CompletableFutureUtils.thenMApplyTupleAsync(cf, executor, fn1, fn2, fn3));
+        return resetCf(CompletableFutureUtils.thenMApplyTupleAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3));
     }
 
     /**
@@ -915,7 +917,7 @@ public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenMApplyTupleAsync(
     public <U1, U2, U3, U4> Cffu<Tuple4<U1, U2, U3, U4>> thenMApplyTupleAsync(
             Executor executor, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4) {
-        return resetCf(CompletableFutureUtils.thenMApplyTupleAsync(cf, executor, fn1, fn2, fn3, fn4));
+        return resetCf(CompletableFutureUtils.thenMApplyTupleAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3, fn4));
     }
 
     /**
@@ -935,7 +937,7 @@ public <U1, U2, U3, U4, U5> Cffu<Tuple5<U1, U2, U3, U4, U5>> thenMApplyTupleAsyn
             Executor executor, Function<? super T, ? extends U1> fn1, Function<? super T, ? extends U2> fn2,
             Function<? super T, ? extends U3> fn3, Function<? super T, ? extends U4> fn4,
             Function<? super T, ? extends U5> fn5) {
-        return resetCf(CompletableFutureUtils.thenMApplyTupleAsync(cf, executor, fn1, fn2, fn3, fn4, fn5));
+        return resetCf(CompletableFutureUtils.thenMApplyTupleAsync(cf, cffuScreenedExecutor(executor), fn1, fn2, fn3, fn4, fn5));
     }
 
     // endregion
@@ -999,7 +1001,7 @@ public <U, V> Cffu<V> thenCombineFailFastAsync(
     @CheckReturnValue(explanation = "should use the returned Cffu; otherwise, prefer method `thenAcceptBothFailFastAsync`")
     public <U, V> Cffu<V> thenCombineFailFastAsync(
             CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn, Executor executor) {
-        return resetCf(CompletableFutureUtils.thenCombineFailFastAsync(cf, other, fn, executor));
+        return resetCf(CompletableFutureUtils.thenCombineFailFastAsync(cf, other, fn, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1048,7 +1050,7 @@ public <U> Cffu<Void> thenAcceptBothFailFastAsync(
      */
     public <U> Cffu<Void> thenAcceptBothFailFastAsync(
             CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor) {
-        return resetCf(CompletableFutureUtils.thenAcceptBothFailFastAsync(cf, other, action, executor));
+        return resetCf(CompletableFutureUtils.thenAcceptBothFailFastAsync(cf, other, action, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1090,7 +1092,7 @@ public Cffu<Void> runAfterBothFailFastAsync(CompletionStage<?> other, Runnable a
      * @param executor the executor to use for asynchronous execution
      */
     public Cffu<Void> runAfterBothFailFastAsync(CompletionStage<?> other, Runnable action, Executor executor) {
-        return resetCf(CompletableFutureUtils.runAfterBothFailFastAsync(cf, other, action, executor));
+        return resetCf(CompletableFutureUtils.runAfterBothFailFastAsync(cf, other, action, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1145,7 +1147,7 @@ public <U, V> Cffu<V> thenCombineAsync(
     @Override
     public <U, V> Cffu<V> thenCombineAsync(
             CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn, Executor executor) {
-        return resetCf(cf.thenCombineAsync(other, fn, executor));
+        return resetCf(cf.thenCombineAsync(other, fn, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1194,7 +1196,7 @@ public <U> Cffu<Void> thenAcceptBothAsync(
     @Override
     public <U> Cffu<Void> thenAcceptBothAsync(
             CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor) {
-        return resetCf(cf.thenAcceptBothAsync(other, action, executor));
+        return resetCf(cf.thenAcceptBothAsync(other, action, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1237,7 +1239,7 @@ public Cffu<Void> runAfterBothAsync(CompletionStage<?> other, Runnable action) {
      */
     @Override
     public Cffu<Void> runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor) {
-        return resetCf(cf.runAfterBothAsync(other, action, executor));
+        return resetCf(cf.runAfterBothAsync(other, action, cffuScreenedExecutor(executor)));
     }
 
     // endregion
@@ -1288,7 +1290,7 @@ public <U> Cffu<U> applyToEitherSuccessAsync(CompletionStage<? extends T> other,
     @CheckReturnValue(explanation = "should use the returned Cffu; otherwise, prefer method `acceptEitherSuccessAsync`")
     public <U> Cffu<U> applyToEitherSuccessAsync(
             CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor) {
-        return resetCf(CompletableFutureUtils.applyToEitherSuccessAsync(cf, other, fn, executor));
+        return resetCf(CompletableFutureUtils.applyToEitherSuccessAsync(cf, other, fn, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1324,7 +1326,7 @@ public Cffu<Void> acceptEitherSuccessAsync(CompletionStage<? extends T> other, C
      */
     public Cffu<Void> acceptEitherSuccessAsync(
             CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor) {
-        return resetCf(CompletableFutureUtils.acceptEitherSuccessAsync(cf, other, action, executor));
+        return resetCf(CompletableFutureUtils.acceptEitherSuccessAsync(cf, other, action, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1363,7 +1365,7 @@ public Cffu<Void> runAfterEitherSuccessAsync(CompletionStage<?> other, Runnable
      * @param executor the executor to use for asynchronous execution
      */
     public Cffu<Void> runAfterEitherSuccessAsync(CompletionStage<?> other, Runnable action, Executor executor) {
-        return resetCf(CompletableFutureUtils.runAfterEitherSuccessAsync(cf, other, action, executor));
+        return resetCf(CompletableFutureUtils.runAfterEitherSuccessAsync(cf, other, action, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1414,7 +1416,7 @@ public <U> Cffu<U> applyToEitherAsync(CompletionStage<? extends T> other, Functi
     @Override
     public <U> Cffu<U> applyToEitherAsync(
             CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor) {
-        return resetCf(cf.applyToEitherAsync(other, fn, executor));
+        return resetCf(cf.applyToEitherAsync(other, fn, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1459,7 +1461,7 @@ public Cffu<Void> acceptEitherAsync(CompletionStage<? extends T> other, Consumer
     @Override
     public Cffu<Void> acceptEitherAsync(
             CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor) {
-        return resetCf(cf.acceptEitherAsync(other, action, executor));
+        return resetCf(cf.acceptEitherAsync(other, action, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1502,7 +1504,7 @@ public Cffu<Void> runAfterEitherAsync(CompletionStage<?> other, Runnable action)
      */
     @Override
     public Cffu<Void> runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor) {
-        return resetCf(cf.runAfterEitherAsync(other, action, executor));
+        return resetCf(cf.runAfterEitherAsync(other, action, cffuScreenedExecutor(executor)));
     }
 
     // endregion
@@ -1573,7 +1575,7 @@ public <X extends Throwable> Cffu<T> catchingAsync(
      */
     public <X extends Throwable> Cffu<T> catchingAsync(
             Class<X> exceptionType, Function<? super X, ? extends T> fallback, Executor executor) {
-        return resetCf(CompletableFutureUtils.catchingAsync(cf, exceptionType, fallback, executor));
+        return resetCf(CompletableFutureUtils.catchingAsync(cf, exceptionType, fallback, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1632,7 +1634,7 @@ public Cffu<T> exceptionallyAsync(Function<Throwable, ? extends T> fn) {
      */
     @Override
     public Cffu<T> exceptionallyAsync(Function<Throwable, ? extends T> fn, Executor executor) {
-        return resetCf(CompletableFutureUtils.exceptionallyAsync(cf, fn, executor));
+        return resetCf(CompletableFutureUtils.exceptionallyAsync(cf, fn, cffuScreenedExecutor(executor)));
     }
 
     // endregion
@@ -1658,7 +1660,7 @@ public Cffu<T> exceptionallyAsync(Function<Throwable, ? extends T> fn, Executor
      */
     public Cffu<T> orTimeout(long timeout, TimeUnit unit) {
         checkMinimalStage();
-        return resetCf(CompletableFutureUtils.cffuOrTimeout(cf, timeout, unit, fac.cffuExecutor));
+        return resetCf(CompletableFutureUtils.cffuOrTimeout(cf, timeout, unit, fac.cffuExecutor.screened));
     }
 
     /**
@@ -1715,7 +1717,7 @@ public Cffu<T> unsafeOrTimeout(long timeout, TimeUnit unit) {
      */
     public Cffu<T> completeOnTimeout(@Nullable T value, long timeout, TimeUnit unit) {
         checkMinimalStage();
-        return resetCf(CompletableFutureUtils.cffuCompleteOnTimeout(cf, value, timeout, unit, fac.cffuExecutor));
+        return resetCf(CompletableFutureUtils.cffuCompleteOnTimeout(cf, value, timeout, unit, fac.cffuExecutor.screened));
     }
 
     /**
@@ -1817,7 +1819,7 @@ public <U> Cffu<U> thenComposeAsync(Function<? super T, ? extends CompletionStag
      */
     @Override
     public <U> Cffu<U> thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor) {
-        return resetCf(cf.thenComposeAsync(fn, executor));
+        return resetCf(cf.thenComposeAsync(fn, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1881,7 +1883,7 @@ public <X extends Throwable> Cffu<T> catchingComposeAsync(
      */
     public <X extends Throwable> Cffu<T> catchingComposeAsync(
             Class<X> exceptionType, Function<? super X, ? extends CompletionStage<T>> fallback, Executor executor) {
-        return resetCf(CompletableFutureUtils.catchingComposeAsync(cf, exceptionType, fallback, executor));
+        return resetCf(CompletableFutureUtils.catchingComposeAsync(cf, exceptionType, fallback, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1935,7 +1937,7 @@ public Cffu<T> exceptionallyComposeAsync(Function<Throwable, ? extends Completio
      */
     @Override
     public Cffu<T> exceptionallyComposeAsync(Function<Throwable, ? extends CompletionStage<T>> fn, Executor executor) {
-        return resetCf(CompletableFutureUtils.exceptionallyComposeAsync(cf, fn, executor));
+        return resetCf(CompletableFutureUtils.exceptionallyComposeAsync(cf, fn, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -1989,7 +1991,7 @@ public <U> Cffu<U> handleAsync(BiFunction<? super T, Throwable, ? extends U> fn)
     @CheckReturnValue(explanation = "should use the returned Cffu; otherwise, prefer method `peekAsync`")
     @Override
     public <U> Cffu<U> handleAsync(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor) {
-        return resetCf(cf.handleAsync(fn, executor));
+        return resetCf(cf.handleAsync(fn, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -2062,7 +2064,7 @@ public Cffu<T> whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action
     @CheckReturnValue(explanation = "should use the returned Cffu; otherwise, prefer method `peekAsync`")
     @Override
     public Cffu<T> whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor) {
-        return resetCf(cf.whenCompleteAsync(action, executor));
+        return resetCf(cf.whenCompleteAsync(action, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -2143,7 +2145,7 @@ public Cffu<T> peekAsync(BiConsumer<? super T, ? super Throwable> action) {
      */
     @Contract("_, _ -> this")
     public Cffu<T> peekAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor) {
-        CompletableFutureUtils.peekAsync(cf, action, executor);
+        CompletableFutureUtils.peekAsync(cf, action, cffuScreenedExecutor(executor));
         return this;
     }
 
@@ -2434,8 +2436,7 @@ public boolean complete(@Nullable T value) {
      */
     @Contract("_ -> this")
     public Cffu<T> completeAsync(Supplier<? extends T> supplier) {
-        // NOTE: do NOT translate executor to screened executor; same as CompletableFuture.completeAsync
-        return completeAsync(supplier, fac.cffuExecutor.unscreened);
+        return completeAsync(supplier, fac.cffuExecutor);
     }
 
     /**
@@ -2449,7 +2450,8 @@ public Cffu<T> completeAsync(Supplier<? extends T> supplier) {
     @Contract("_, _ -> this")
     public Cffu<T> completeAsync(Supplier<? extends T> supplier, Executor executor) {
         checkMinimalStage();
-        CompletableFutureUtils.completeAsync(cf, supplier, executor);
+        // NOTE: do NOT translate executor to screened executor; same as CompletableFuture.completeAsync
+        CompletableFutureUtils.completeAsync(cf, supplier, cffuUnscreenedExecutor(executor));
         return this;
     }
 
@@ -2473,8 +2475,7 @@ public boolean completeExceptionally(Throwable ex) {
      */
     @Contract("_ -> this")
     public Cffu<T> completeExceptionallyAsync(Supplier<? extends Throwable> supplier) {
-        // NOTE: do NOT translate executor to screened executor; same as CompletableFuture.completeAsync
-        return completeExceptionallyAsync(supplier, fac.cffuExecutor.unscreened);
+        return completeExceptionallyAsync(supplier, fac.cffuExecutor);
     }
 
     /**
@@ -2488,7 +2489,8 @@ public Cffu<T> completeExceptionallyAsync(Supplier<? extends Throwable> supplier
     @Contract("_, _ -> this")
     public Cffu<T> completeExceptionallyAsync(Supplier<? extends Throwable> supplier, Executor executor) {
         checkMinimalStage();
-        CompletableFutureUtils.completeExceptionallyAsync(cf, supplier, executor);
+        // NOTE: do NOT translate executor to screened executor; same as CompletableFuture.completeAsync
+        CompletableFutureUtils.completeExceptionallyAsync(cf, supplier, cffuUnscreenedExecutor(executor));
         return this;
     }
 
diff --git a/cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java b/cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java
index 0e5d01f4..843835b8 100644
--- a/cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java
+++ b/cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java
@@ -18,6 +18,8 @@
 import java.util.concurrent.TimeUnit;
 import java.util.function.Supplier;
 
+import static io.foldright.cffu.CffuFactoryBuilder.cffuScreenedExecutor;
+import static io.foldright.cffu.CffuFactoryBuilder.cffuUnscreenedExecutor;
 import static java.util.Objects.requireNonNull;
 
 
@@ -132,7 +134,7 @@ public <T> Cffu<T> supplyAsync(Supplier<T> supplier) {
      */
     @CheckReturnValue(explanation = "should use the returned Cffu; otherwise, prefer method `runAsync`")
     public <T> Cffu<T> supplyAsync(Supplier<T> supplier, Executor executor) {
-        return create(CompletableFuture.supplyAsync(supplier, executor));
+        return create(CompletableFuture.supplyAsync(supplier, cffuScreenedExecutor(executor)));
     }
 
     /**
@@ -153,7 +155,7 @@ public Cffu<Void> runAsync(Runnable action) {
      * @param executor the executor to use for asynchronous execution
      */
     public Cffu<Void> runAsync(Runnable action, Executor executor) {
-        return create(CompletableFuture.runAsync(action, executor));
+        return create(CompletableFuture.runAsync(action, cffuScreenedExecutor(executor)));
     }
 
     // endregion
@@ -183,7 +185,7 @@ public final <T> Cffu<List<T>> mSupplyFailFastAsync(Supplier<? extends T>... sup
      */
     @SafeVarargs
     public final <T> Cffu<List<T>> mSupplyFailFastAsync(Executor executor, Supplier<? extends T>... suppliers) {
-        return create(CompletableFutureUtils.mSupplyFailFastAsync(executor, suppliers));
+        return create(CompletableFutureUtils.mSupplyFailFastAsync(cffuScreenedExecutor(executor), suppliers));
     }
 
     /**
@@ -207,7 +209,7 @@ public final <T> Cffu<List<T>> mSupplyAllSuccessAsync(
     @SafeVarargs
     public final <T> Cffu<List<T>> mSupplyAllSuccessAsync(
             Executor executor, @Nullable T valueIfFailed, Supplier<? extends T>... suppliers) {
-        return create(CompletableFutureUtils.mSupplyAllSuccessAsync(executor, valueIfFailed, suppliers));
+        return create(CompletableFutureUtils.mSupplyAllSuccessAsync(cffuScreenedExecutor(executor), valueIfFailed, suppliers));
     }
 
     /**
@@ -234,7 +236,7 @@ public final <T> Cffu<List<T>> mSupplyMostSuccessAsync(
     public final <T> Cffu<List<T>> mSupplyMostSuccessAsync(
             Executor executor, @Nullable T valueIfNotSuccess, long timeout, TimeUnit unit,
             Supplier<? extends T>... suppliers) {
-        return create(CompletableFutureUtils.mSupplyMostSuccessAsync(executor, valueIfNotSuccess, timeout, unit, suppliers));
+        return create(CompletableFutureUtils.mSupplyMostSuccessAsync(cffuScreenedExecutor(executor), valueIfNotSuccess, timeout, unit, suppliers));
     }
 
     /**
@@ -256,7 +258,7 @@ public final <T> Cffu<List<T>> mSupplyAsync(Supplier<? extends T>... suppliers)
     @SafeVarargs
     public final <T> Cffu<List<T>> mSupplyAsync(
             Executor executor, Supplier<? extends T>... suppliers) {
-        return create(CompletableFutureUtils.mSupplyAsync(executor, suppliers));
+        return create(CompletableFutureUtils.mSupplyAsync(cffuScreenedExecutor(executor), suppliers));
     }
 
     /**
@@ -277,7 +279,7 @@ public final <T> Cffu<T> mSupplyAnySuccessAsync(Supplier<? extends T>... supplie
      */
     @SafeVarargs
     public final <T> Cffu<T> mSupplyAnySuccessAsync(Executor executor, Supplier<? extends T>... suppliers) {
-        return create(CompletableFutureUtils.mSupplyAnySuccessAsync(executor, suppliers));
+        return create(CompletableFutureUtils.mSupplyAnySuccessAsync(cffuScreenedExecutor(executor), suppliers));
     }
 
     /**
@@ -298,7 +300,7 @@ public final <T> Cffu<T> mSupplyAnyAsync(Supplier<? extends T>... suppliers) {
      */
     @SafeVarargs
     public final <T> Cffu<T> mSupplyAnyAsync(Executor executor, Supplier<? extends T>... suppliers) {
-        return create(CompletableFutureUtils.mSupplyAnyAsync(executor, suppliers));
+        return create(CompletableFutureUtils.mSupplyAnyAsync(cffuScreenedExecutor(executor), suppliers));
     }
 
     /**
@@ -317,7 +319,7 @@ public Cffu<Void> mRunFailFastAsync(Runnable... actions) {
      * See the {@link #allFailFastOf allFailFastOf} documentation for the rules of result computation.
      */
     public Cffu<Void> mRunFailFastAsync(Executor executor, Runnable... actions) {
-        return create(CompletableFutureUtils.mRunFailFastAsync(executor, actions));
+        return create(CompletableFutureUtils.mRunFailFastAsync(cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -335,7 +337,7 @@ public Cffu<Void> mRunAsync(Runnable... actions) {
      * See the {@link #allOf allOf} documentation for the rules of result computation.
      */
     public Cffu<Void> mRunAsync(Executor executor, Runnable... actions) {
-        return create(CompletableFutureUtils.mRunAsync(executor, actions));
+        return create(CompletableFutureUtils.mRunAsync(cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -354,7 +356,7 @@ public Cffu<Void> mRunAnySuccessAsync(Runnable... actions) {
      * See the {@link #anySuccessOf anySuccessOf} documentation for the rules of result computation.
      */
     public Cffu<Void> mRunAnySuccessAsync(Executor executor, Runnable... actions) {
-        return create(CompletableFutureUtils.mRunAnySuccessAsync(executor, actions));
+        return create(CompletableFutureUtils.mRunAnySuccessAsync(cffuScreenedExecutor(executor), actions));
     }
 
     /**
@@ -372,7 +374,7 @@ public Cffu<Void> mRunAnyAsync(Runnable... actions) {
      * See the {@link #anyOf anyOf} documentation for the rules of result computation.
      */
     public Cffu<Void> mRunAnyAsync(Executor executor, Runnable... actions) {
-        return create(CompletableFutureUtils.mRunAnyAsync(executor, actions));
+        return create(CompletableFutureUtils.mRunAnyAsync(cffuScreenedExecutor(executor), actions));
     }
 
     // endregion
@@ -393,7 +395,7 @@ public <T1, T2> Cffu<Tuple2<T1, T2>> mSupplyTupleFailFastAsync(
      */
     public <T1, T2> Cffu<Tuple2<T1, T2>> mSupplyTupleFailFastAsync(
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2) {
-        return create(CompletableFutureUtils.mSupplyTupleFailFastAsync(executor, supplier1, supplier2));
+        return create(CompletableFutureUtils.mSupplyTupleFailFastAsync(cffuScreenedExecutor(executor), supplier1, supplier2));
     }
 
     /**
@@ -410,7 +412,7 @@ public <T1, T2, T3> Cffu<Tuple3<T1, T2, T3>> mSupplyTupleFailFastAsync(
     public <T1, T2, T3> Cffu<Tuple3<T1, T2, T3>> mSupplyTupleFailFastAsync(
             Executor executor, Supplier<? extends T1> supplier1,
             Supplier<? extends T2> supplier2, Supplier<? extends T3> supplier3) {
-        return create(CompletableFutureUtils.mSupplyTupleFailFastAsync(executor, supplier1, supplier2, supplier3));
+        return create(CompletableFutureUtils.mSupplyTupleFailFastAsync(cffuScreenedExecutor(executor), supplier1, supplier2, supplier3));
     }
 
     /**
@@ -428,7 +430,7 @@ public <T1, T2, T3, T4> Cffu<Tuple4<T1, T2, T3, T4>> mSupplyTupleFailFastAsync(
     public <T1, T2, T3, T4> Cffu<Tuple4<T1, T2, T3, T4>> mSupplyTupleFailFastAsync(
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2,
             Supplier<? extends T3> supplier3, Supplier<? extends T4> supplier4) {
-        return create(CompletableFutureUtils.mSupplyTupleFailFastAsync(executor, supplier1, supplier2, supplier3, supplier4));
+        return create(CompletableFutureUtils.mSupplyTupleFailFastAsync(cffuScreenedExecutor(executor), supplier1, supplier2, supplier3, supplier4));
     }
 
     /**
@@ -447,7 +449,7 @@ public <T1, T2, T3, T4, T5> Cffu<Tuple5<T1, T2, T3, T4, T5>> mSupplyTupleFailFas
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2,
             Supplier<? extends T3> supplier3, Supplier<? extends T4> supplier4, Supplier<? extends T5> supplier5) {
         return create(CompletableFutureUtils.mSupplyTupleFailFastAsync(
-                executor, supplier1, supplier2, supplier3, supplier4, supplier5));
+                cffuScreenedExecutor(executor), supplier1, supplier2, supplier3, supplier4, supplier5));
     }
 
     /**
@@ -469,7 +471,7 @@ public <T1, T2> Cffu<Tuple2<T1, T2>> mSupplyAllSuccessTupleAsync(
      */
     public <T1, T2> Cffu<Tuple2<T1, T2>> mSupplyAllSuccessTupleAsync(
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2) {
-        return create(CompletableFutureUtils.mSupplyAllSuccessTupleAsync(executor, supplier1, supplier2));
+        return create(CompletableFutureUtils.mSupplyAllSuccessTupleAsync(cffuScreenedExecutor(executor), supplier1, supplier2));
     }
 
     /**
@@ -492,7 +494,7 @@ public <T1, T2, T3> Cffu<Tuple3<T1, T2, T3>> mSupplyAllSuccessTupleAsync(
     public <T1, T2, T3> Cffu<Tuple3<T1, T2, T3>> mSupplyAllSuccessTupleAsync(
             Executor executor, Supplier<? extends T1> supplier1,
             Supplier<? extends T2> supplier2, Supplier<? extends T3> supplier3) {
-        return create(CompletableFutureUtils.mSupplyAllSuccessTupleAsync(executor, supplier1, supplier2, supplier3));
+        return create(CompletableFutureUtils.mSupplyAllSuccessTupleAsync(cffuScreenedExecutor(executor), supplier1, supplier2, supplier3));
     }
 
     /**
@@ -516,7 +518,7 @@ public <T1, T2, T3, T4> Cffu<Tuple4<T1, T2, T3, T4>> mSupplyAllSuccessTupleAsync
     public <T1, T2, T3, T4> Cffu<Tuple4<T1, T2, T3, T4>> mSupplyAllSuccessTupleAsync(
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2,
             Supplier<? extends T3> supplier3, Supplier<? extends T4> supplier4) {
-        return create(CompletableFutureUtils.mSupplyAllSuccessTupleAsync(executor, supplier1, supplier2, supplier3, supplier4));
+        return create(CompletableFutureUtils.mSupplyAllSuccessTupleAsync(cffuScreenedExecutor(executor), supplier1, supplier2, supplier3, supplier4));
     }
 
     /**
@@ -541,7 +543,7 @@ public <T1, T2, T3, T4, T5> Cffu<Tuple5<T1, T2, T3, T4, T5>> mSupplyAllSuccessTu
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2,
             Supplier<? extends T3> supplier3, Supplier<? extends T4> supplier4, Supplier<? extends T5> supplier5) {
         return create(CompletableFutureUtils.mSupplyAllSuccessTupleAsync(
-                executor, supplier1, supplier2, supplier3, supplier4, supplier5));
+                cffuScreenedExecutor(executor), supplier1, supplier2, supplier3, supplier4, supplier5));
     }
 
     /**
@@ -565,7 +567,7 @@ public <T1, T2> Cffu<Tuple2<T1, T2>> mSupplyMostSuccessTupleAsync(
     public <T1, T2> Cffu<Tuple2<T1, T2>> mSupplyMostSuccessTupleAsync(
             Executor executor, long timeout, TimeUnit unit,
             Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2) {
-        return create(CompletableFutureUtils.mSupplyMostSuccessTupleAsync(executor, timeout, unit, supplier1, supplier2));
+        return create(CompletableFutureUtils.mSupplyMostSuccessTupleAsync(cffuScreenedExecutor(executor), timeout, unit, supplier1, supplier2));
     }
 
     /**
@@ -591,7 +593,7 @@ public <T1, T2, T3> Cffu<Tuple3<T1, T2, T3>> mSupplyMostSuccessTupleAsync(
             Executor executor, long timeout, TimeUnit unit,
             Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2, Supplier<? extends T3> supplier3) {
         return create(CompletableFutureUtils.mSupplyMostSuccessTupleAsync(
-                executor, timeout, unit, supplier1, supplier2, supplier3));
+                cffuScreenedExecutor(executor), timeout, unit, supplier1, supplier2, supplier3));
     }
 
     /**
@@ -617,7 +619,7 @@ public <T1, T2, T3, T4> Cffu<Tuple4<T1, T2, T3, T4>> mSupplyMostSuccessTupleAsyn
             Executor executor, long timeout, TimeUnit unit, Supplier<? extends T1> supplier1,
             Supplier<? extends T2> supplier2, Supplier<? extends T3> supplier3, Supplier<? extends T4> supplier4) {
         return create(CompletableFutureUtils.mSupplyMostSuccessTupleAsync(
-                executor, timeout, unit, supplier1, supplier2, supplier3, supplier4));
+                cffuScreenedExecutor(executor), timeout, unit, supplier1, supplier2, supplier3, supplier4));
     }
 
     /**
@@ -645,7 +647,7 @@ public <T1, T2, T3, T4, T5> Cffu<Tuple5<T1, T2, T3, T4, T5>> mSupplyMostSuccessT
             Supplier<? extends T2> supplier2, Supplier<? extends T3> supplier3,
             Supplier<? extends T4> supplier4, Supplier<? extends T5> supplier5) {
         return create(CompletableFutureUtils.mSupplyMostSuccessTupleAsync(
-                executor, timeout, unit, supplier1, supplier2, supplier3, supplier4, supplier5));
+                cffuScreenedExecutor(executor), timeout, unit, supplier1, supplier2, supplier3, supplier4, supplier5));
     }
 
     /**
@@ -661,7 +663,7 @@ public <T1, T2> Cffu<Tuple2<T1, T2>> mSupplyTupleAsync(
      */
     public <T1, T2> Cffu<Tuple2<T1, T2>> mSupplyTupleAsync(
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2) {
-        return create(CompletableFutureUtils.mSupplyTupleAsync(executor, supplier1, supplier2));
+        return create(CompletableFutureUtils.mSupplyTupleAsync(cffuScreenedExecutor(executor), supplier1, supplier2));
     }
 
     /**
@@ -678,7 +680,7 @@ public <T1, T2, T3> Cffu<Tuple3<T1, T2, T3>> mSupplyTupleAsync(
     public <T1, T2, T3> Cffu<Tuple3<T1, T2, T3>> mSupplyTupleAsync(
             Executor executor, Supplier<? extends T1> supplier1,
             Supplier<? extends T2> supplier2, Supplier<? extends T3> supplier3) {
-        return create(CompletableFutureUtils.mSupplyTupleAsync(executor, supplier1, supplier2, supplier3));
+        return create(CompletableFutureUtils.mSupplyTupleAsync(cffuScreenedExecutor(executor), supplier1, supplier2, supplier3));
     }
 
     /**
@@ -696,7 +698,7 @@ public <T1, T2, T3, T4> Cffu<Tuple4<T1, T2, T3, T4>> mSupplyTupleAsync(
     public <T1, T2, T3, T4> Cffu<Tuple4<T1, T2, T3, T4>> mSupplyTupleAsync(
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2,
             Supplier<? extends T3> supplier3, Supplier<? extends T4> supplier4) {
-        return create(CompletableFutureUtils.mSupplyTupleAsync(executor, supplier1, supplier2, supplier3, supplier4));
+        return create(CompletableFutureUtils.mSupplyTupleAsync(cffuScreenedExecutor(executor), supplier1, supplier2, supplier3, supplier4));
     }
 
     /**
@@ -715,7 +717,7 @@ public <T1, T2, T3, T4, T5> Cffu<Tuple5<T1, T2, T3, T4, T5>> mSupplyTupleAsync(
             Executor executor, Supplier<? extends T1> supplier1, Supplier<? extends T2> supplier2,
             Supplier<? extends T3> supplier3, Supplier<? extends T4> supplier4, Supplier<? extends T5> supplier5) {
         return create(CompletableFutureUtils.mSupplyTupleAsync(
-                executor, supplier1, supplier2, supplier3, supplier4, supplier5));
+                cffuScreenedExecutor(executor), supplier1, supplier2, supplier3, supplier4, supplier5));
     }
 
     // endregion
@@ -793,7 +795,7 @@ public final <T> Cffu<List<T>> allSuccessResultsOf(
     public final <T> Cffu<List<T>> mostSuccessResultsOf(
             @Nullable T valueIfNotSuccess, long timeout, TimeUnit unit, CompletionStage<? extends T>... cfs) {
         return create(CompletableFutureUtils.mostSuccessResultsOf(
-                cffuExecutor, valueIfNotSuccess, timeout, unit, cfs));
+                cffuExecutor.screened, valueIfNotSuccess, timeout, unit, cfs));
     }
 
     /**
@@ -1016,7 +1018,7 @@ public <T1, T2, T3, T4, T5> Cffu<Tuple5<T1, T2, T3, T4, T5>> allSuccessTupleOf(
     @Contract(pure = true)
     public <T1, T2> Cffu<Tuple2<T1, T2>> mostSuccessTupleOf(
             long timeout, TimeUnit unit, CompletionStage<? extends T1> cf1, CompletionStage<? extends T2> cf2) {
-        return create(CompletableFutureUtils.mostSuccessTupleOf(cffuExecutor, timeout, unit, cf1, cf2));
+        return create(CompletableFutureUtils.mostSuccessTupleOf(cffuScreenedExecutor(cffuExecutor), timeout, unit, cf1, cf2));
     }
 
     /**
@@ -1030,7 +1032,8 @@ public <T1, T2> Cffu<Tuple2<T1, T2>> mostSuccessTupleOf(
     public <T1, T2, T3> Cffu<Tuple3<T1, T2, T3>> mostSuccessTupleOf(
             long timeout, TimeUnit unit,
             CompletionStage<? extends T1> cf1, CompletionStage<? extends T2> cf2, CompletionStage<? extends T3> cf3) {
-        return create(CompletableFutureUtils.mostSuccessTupleOf(cffuExecutor, timeout, unit, cf1, cf2, cf3));
+        return create(CompletableFutureUtils.mostSuccessTupleOf(
+                cffuExecutor.screened, timeout, unit, cf1, cf2, cf3));
     }
 
     /**
@@ -1045,7 +1048,8 @@ public <T1, T2, T3, T4> Cffu<Tuple4<T1, T2, T3, T4>> mostSuccessTupleOf(
             long timeout, TimeUnit unit,
             CompletionStage<? extends T1> cf1, CompletionStage<? extends T2> cf2,
             CompletionStage<? extends T3> cf3, CompletionStage<? extends T4> cf4) {
-        return create(CompletableFutureUtils.mostSuccessTupleOf(cffuExecutor, timeout, unit, cf1, cf2, cf3, cf4));
+        return create(CompletableFutureUtils.mostSuccessTupleOf(
+                cffuExecutor.screened, timeout, unit, cf1, cf2, cf3, cf4));
     }
 
     /**
@@ -1060,7 +1064,8 @@ public <T1, T2, T3, T4, T5> Cffu<Tuple5<T1, T2, T3, T4, T5>> mostSuccessTupleOf(
             long timeout, TimeUnit unit,
             CompletionStage<? extends T1> cf1, CompletionStage<? extends T2> cf2, CompletionStage<? extends T3> cf3,
             CompletionStage<? extends T4> cf4, CompletionStage<? extends T5> cf5) {
-        return create(CompletableFutureUtils.mostSuccessTupleOf(cffuExecutor, timeout, unit, cf1, cf2, cf3, cf4, cf5));
+        return create(CompletableFutureUtils.mostSuccessTupleOf(
+                cffuExecutor.screened, timeout, unit, cf1, cf2, cf3, cf4, cf5));
     }
 
     /**
@@ -1226,7 +1231,7 @@ public final <T> Cffu<T>[] toCffuArray(CompletionStage<T>... stages) {
      */
     @Contract(pure = true)
     public Executor delayedExecutor(long delay, TimeUnit unit) {
-        return CompletableFutureUtils.delayedExecutor(delay, unit, cffuExecutor);
+        return delayedExecutor(delay, unit, cffuExecutor);
     }
 
     /**
@@ -1241,7 +1246,8 @@ public Executor delayedExecutor(long delay, TimeUnit unit) {
      */
     @Contract(pure = true)
     public Executor delayedExecutor(long delay, TimeUnit unit, Executor executor) {
-        return CompletableFutureUtils.delayedExecutor(delay, unit, executor);
+        // NOTE: do NOT translate executor to screened executor; same as CompletableFuture.delayedExecutor
+        return CompletableFutureUtils.delayedExecutor(delay, unit, cffuUnscreenedExecutor(executor));
     }
 
     // endregion
diff --git a/cffu-core/src/main/java/io/foldright/cffu/CffuFactoryBuilder.java b/cffu-core/src/main/java/io/foldright/cffu/CffuFactoryBuilder.java
index 1b8693b0..338803fb 100644
--- a/cffu-core/src/main/java/io/foldright/cffu/CffuFactoryBuilder.java
+++ b/cffu-core/src/main/java/io/foldright/cffu/CffuFactoryBuilder.java
@@ -113,11 +113,12 @@ private CffuExecutorWrapper(Executor defaultExecutor) {
         }
 
         /**
-         * Delegates execution to {@link #screened} to treat this executor same as screened executor.
+         * This method is never called directly. Instead, use the related {@link #screened}/{@link #unscreened} executor
+         * from method {@link #cffuScreenedExecutor(Executor)}/{@link #cffuUnscreenedExecutor(Executor)} respectively.
          */
         @Override
         public void execute(Runnable command) {
-            screened.execute(command);
+            throw new UnsupportedOperationException();
         }
 
         @Override
diff --git a/cffu-core/src/test/java/io/foldright/cffu/CffuFactoryTest.java b/cffu-core/src/test/java/io/foldright/cffu/CffuFactoryTest.java
index 3eb080d9..d4a963ad 100644
--- a/cffu-core/src/test/java/io/foldright/cffu/CffuFactoryTest.java
+++ b/cffu-core/src/test/java/io/foldright/cffu/CffuFactoryTest.java
@@ -916,8 +916,6 @@ void test_executorSetting_commonPool() throws Exception {
         assertEquals(n, fac.supplyAsync(() -> n).get());
     }
 
-    // FIXME bug to be fixed!
-    @Disabled
     @Test
     void test_executorSetting_MayRunIn_ThreadPerTaskExecutor() throws Exception {
         final boolean USE_COMMON_POOL = ForkJoinPool.getCommonPoolParallelism() > 1;