From 98675d287bd009aab719c9cf1aeb2eedac3060f8 Mon Sep 17 00:00:00 2001 From: pcshao Date: Wed, 11 Feb 2026 16:25:41 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8D=E8=87=AA=E5=AE=9A?= =?UTF-8?q?=E4=B9=89@Async=E7=BA=BF=E7=A8=8B=E6=B1=A0=E7=9A=84=E7=BA=BF?= =?UTF-8?q?=E7=A8=8B=E5=91=BD=E5=90=8D=E6=80=BB=E6=98=AF=E4=B8=BAel-async-?= =?UTF-8?q?1=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/me/zhengjie/config/AsyncExecutor.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/eladmin-common/src/main/java/me/zhengjie/config/AsyncExecutor.java b/eladmin-common/src/main/java/me/zhengjie/config/AsyncExecutor.java index ee0764062..3242a9305 100644 --- a/eladmin-common/src/main/java/me/zhengjie/config/AsyncExecutor.java +++ b/eladmin-common/src/main/java/me/zhengjie/config/AsyncExecutor.java @@ -63,6 +63,11 @@ public void setQueueCapacity(int queueCapacity) { AsyncExecutor.queueCapacity = queueCapacity; } + /** + * 定义自定义异步处理线程池，线程名的标号自增计数器 + */ + private static AtomicInteger atomicInteger = new AtomicInteger(1); + /** * 自定义线程池，用法 @Async * @return Executor @@ -70,7 +75,7 @@ public void setQueueCapacity(int queueCapacity) { @Override public Executor getAsyncExecutor() { // 自定义工厂 - ThreadFactory factory = r -> new Thread(r, "el-async-" + new AtomicInteger(1).getAndIncrement()); + ThreadFactory factory = r -> new Thread(r, "el-async-" + atomicInteger.getAndIncrement()); // 自定义线程池 return new ThreadPoolExecutor(corePoolSize, maxPoolSize, keepAliveSeconds, TimeUnit.SECONDS, new ArrayBlockingQueue<>(queueCapacity), factory,