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 4fc1766..98e844f 100644 --- a/src/main/java/com/jd/platform/async/executor/Async.java +++ b/src/main/java/com/jd/platform/async/executor/Async.java @@ -71,7 +71,7 @@ public class Async { groupCallback = new DefaultGroupCallback(); } IGroupCallback finalGroupCallback = groupCallback; - CompletableFuture.runAsync(() -> { + COMMON_POOL.submit(() -> { try { boolean success = beginWork(timeout, COMMON_POOL, workerWrapper); if (success) {