From bdfced98eeecda0add1c34ac8ef6d58cd44c898a Mon Sep 17 00:00:00 2001 From: guoshengxiong <1923636941@qq.com> Date: Mon, 20 May 2024 10:05:09 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=B7=E5=BA=B7=E7=9A=84=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E6=94=B9=E6=88=90mdc=E7=9A=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/zhgd/xmgl/config/AsyncConfig.java | 28 +++++++++---------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/zhgd/xmgl/config/AsyncConfig.java b/src/main/java/com/zhgd/xmgl/config/AsyncConfig.java index fd6d32585..80e45338c 100644 --- a/src/main/java/com/zhgd/xmgl/config/AsyncConfig.java +++ b/src/main/java/com/zhgd/xmgl/config/AsyncConfig.java @@ -354,8 +354,8 @@ public class AsyncConfig { } @Bean("carInfoExecutor") - public ThreadPoolTaskExecutor carInfoExecutor() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + public MdcThreadPoolTaskExecutor carInfoExecutor() { + MdcThreadPoolTaskExecutor executor = new MdcThreadPoolTaskExecutor(); /** 核心线程数(默认线程数) */ executor.setCorePoolSize(maxPoolSize); /** 最大线程数 */ @@ -373,8 +373,8 @@ public class AsyncConfig { } @Bean("getCrossRecords") - public ThreadPoolTaskExecutor getCrossRecords() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + public MdcThreadPoolTaskExecutor getCrossRecords() { + MdcThreadPoolTaskExecutor executor = new MdcThreadPoolTaskExecutor(); /** 核心线程数(默认线程数) */ executor.setCorePoolSize(maxPoolSize); /** 最大线程数 */ @@ -392,8 +392,8 @@ public class AsyncConfig { } @Bean("getDoorEvents") - public ThreadPoolTaskExecutor getDoorEvents() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + public MdcThreadPoolTaskExecutor getDoorEvents() { + MdcThreadPoolTaskExecutor executor = new MdcThreadPoolTaskExecutor(); /** 核心线程数(默认线程数) */ executor.setCorePoolSize(maxPoolSize); /** 最大线程数 */ @@ -411,8 +411,8 @@ public class AsyncConfig { } @Bean("saveEventCallbackAttendance") - public ThreadPoolTaskExecutor saveEventCallbackAttendance() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + public MdcThreadPoolTaskExecutor saveEventCallbackAttendance() { + MdcThreadPoolTaskExecutor executor = new MdcThreadPoolTaskExecutor(); /** 核心线程数(默认线程数) */ executor.setCorePoolSize(maxPoolSize); /** 最大线程数 */ @@ -430,8 +430,8 @@ public class AsyncConfig { } @Bean("saveEventCallbackCarPassRecord") - public ThreadPoolTaskExecutor saveEventCallbackCarPassRecord() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + public MdcThreadPoolTaskExecutor saveEventCallbackCarPassRecord() { + MdcThreadPoolTaskExecutor executor = new MdcThreadPoolTaskExecutor(); /** 核心线程数(默认线程数) */ executor.setCorePoolSize(maxPoolSize); /** 最大线程数 */ @@ -449,8 +449,8 @@ public class AsyncConfig { } @Bean("saveEventCallbackAiAsync") - public ThreadPoolTaskExecutor saveEventCallbackAiAsync() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + public MdcThreadPoolTaskExecutor saveEventCallbackAiAsync() { + MdcThreadPoolTaskExecutor executor = new MdcThreadPoolTaskExecutor(); /** 核心线程数(默认线程数) */ executor.setCorePoolSize(maxPoolSize); /** 最大线程数 */ @@ -468,8 +468,8 @@ public class AsyncConfig { } @Bean("getRecordForHikvisionTask") - public ThreadPoolTaskExecutor getRecordForHikvisionTask() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + public MdcThreadPoolTaskExecutor getRecordForHikvisionTask() { + MdcThreadPoolTaskExecutor executor = new MdcThreadPoolTaskExecutor(); /** 核心线程数(默认线程数) */ executor.setCorePoolSize(160); /** 最大线程数 */