diff --git a/src/main/java/com/jd/platform/async/executor/Async.java b/src/main/java/com/jd/platform/async/executor/Async.java
index f88d50bd9eb8ef80f096a8c1c7e9913dc1e36c96..c1f778ef3c9290bba8a87ba8059f2af3efd23ff5 100644
--- a/src/main/java/com/jd/platform/async/executor/Async.java
+++ b/src/main/java/com/jd/platform/async/executor/Async.java
@@ -83,36 +83,20 @@ public class Async {
             groupCallback = new DefaultGroupCallback();
         }
         IGroupCallback finalGroupCallback = groupCallback;
-        if (executorService != null) {
-            executorService.submit(() -> {
-                try {
-                    boolean success = beginWork(timeout, executorService, workerWrapper);
-                    if (success) {
-                        finalGroupCallback.success(Arrays.asList(workerWrapper));
-                    } else {
-                        finalGroupCallback.failure(Arrays.asList(workerWrapper), new TimeoutException());
-                    }
-                } catch (ExecutionException | InterruptedException e) {
-                    e.printStackTrace();
-                    finalGroupCallback.failure(Arrays.asList(workerWrapper), e);
-                }
-            });
-        } else {
-            COMMON_POOL.submit(() -> {
-                try {
-                    boolean success = beginWork(timeout, COMMON_POOL, workerWrapper);
-                    if (success) {
-                        finalGroupCallback.success(Arrays.asList(workerWrapper));
-                    } else {
-                        finalGroupCallback.failure(Arrays.asList(workerWrapper), new TimeoutException());
-                    }
-                } catch (ExecutionException | InterruptedException e) {
-                    e.printStackTrace();
-                    finalGroupCallback.failure(Arrays.asList(workerWrapper), e);
+        ExecutorService finalExecutorService = executorService != null ? executorService : COMMON_POOL;
+        finalExecutorService.submit(() -> {
+            try {
+                boolean success = beginWork(timeout, finalExecutorService, workerWrapper);
+                if (success) {
+                    finalGroupCallback.success(Arrays.asList(workerWrapper));
+                } else {
+                    finalGroupCallback.failure(Arrays.asList(workerWrapper), new TimeoutException());
                 }
-            });
-        }
-
+            } catch (ExecutionException | InterruptedException e) {
+                e.printStackTrace();
+                finalGroupCallback.failure(Arrays.asList(workerWrapper), e);
+            }
+        });
     }
 
     /**