From 82dffcdb41b2de3bbf6df90995bc0462f2396723 Mon Sep 17 00:00:00 2001
From: HuTao <tao.hu.bj@partner.lingyue-digital.com>
Date: Tue, 31 Oct 2023 16:56:35 +0800
Subject: [PATCH] =?UTF-8?q?=E9=81=BF=E5=85=8D=E9=87=8D=E5=A4=8D=E4=BB=A3?=
 =?UTF-8?q?=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/jd/platform/async/executor/Async.java | 42 ++++++-------------
 1 file changed, 13 insertions(+), 29 deletions(-)

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 f88d50b..c1f778e 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);
+            }
+        });
     }
 
     /**
-- 
Gitee