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); /** 最大线程数 */