//package com.ltkj.framework.aspectj;
|
//
|
//import com.ltkj.framework.datasource.DynamicDataSourceContextHolder;
|
//import lombok.extern.slf4j.Slf4j;
|
//import org.slf4j.Logger;
|
//import org.slf4j.LoggerFactory;
|
//import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
//
|
////@Slf4j
|
//public class DataSourceAwareThreadPoolTaskExecutor extends ThreadPoolTaskExecutor {
|
// private static final Logger logger = LoggerFactory.getLogger(AsynAspect.class);
|
// @Override
|
// public void execute(Runnable task) {
|
// String dataSource = DynamicDataSourceContextHolder.getDataSourceType();
|
// logger.info("异步传递线程当前线程数据源: {}", dataSource);
|
// Runnable wrappedTask = () -> {
|
// try {
|
// // 将当前数据源传递到异步线程
|
// DynamicDataSourceContextHolder.setDataSourceType(dataSource);
|
// task.run();
|
// } finally {
|
// // 执行完毕后清理数据源
|
// DynamicDataSourceContextHolder.clearDataSourceType();
|
// }
|
// };
|
// super.execute(wrappedTask);
|
// }
|
//}
|
