From 6a77b0976dbf8cda9824b11367a818b3514c9e67 Mon Sep 17 00:00:00 2001 From: wuweifeng10 Date: Mon, 3 Aug 2020 20:42:33 +0800 Subject: [PATCH] =?UTF-8?q?=E7=94=A8CommonPool=E6=9B=BF=E4=BB=A3compleatab?= =?UTF-8?q?le=EF=BC=8C=E9=81=BF=E5=85=8D=E5=A4=A7=E9=87=8F=E5=BC=82?= =?UTF-8?q?=E6=AD=A5=E5=90=8C=E6=97=B6=E6=89=A7=E8=A1=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/jd/platform/async/executor/Async.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) {