Java中通过自定义@ThreadPoolGroup注解实现线程池隔离与路由派发，核心是注解标记、AOP拦截、上下文绑定及动态执行器选择；需手动实现运行时识别注解并按规则分发任务至指定逻辑线程池组。
Java 中通过自定义注解实现线程池隔离（ThreadPoolGroup）和路由派发，核心在于：注解标记 + AOP拦截 + 线程池上下文绑定 + 执行器动态选择。这不是 Spring 原生支持的功能，需手动组合实现，关键在“运行时识别注解、按规则分发任务到指定线程池”。
定义 @ThreadPoolGroup 注解
声明一个可作用于方法的注解，用于标识该方法应被调度到哪个逻辑线程池组：
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface ThreadPoolGroup {
String value() default "default"; // 如 "io", "compute", "cache"
}
value 表示逻辑分组名，不直接对应具体线程池实例，而是作为路由键（Routing Key）。
注册并管理命名线程池组
用 ConcurrentHashMap 管理多个命名的 ThreadPoolExecutor 实例，避免重复创建，支持按需初始化：
- 启动时预定义常用组（如 io、compute），或首次调用时懒加载
- 每个组可配置独立参数（corePoolSize、queue、rejected handler）
- 推荐使用 NamedThreadFactory 为线程打标，便于排查
示例：
public class ThreadPoolRegistry {
private static final Map<string threadpoolexecutor> POOLS = new ConcurrentHashMap();
<pre class="brush:php;toolbar:false;">public static ThreadPoolExecutor get(String group) {
return POOLS.computeIfAbsent(group, key ->
new ThreadPoolExecutor(
2, 8, 60L, TimeUnit.SECONDS,
new LinkedBlockingQueue(1000),
new NamedThreadFactory(key),
new ThreadPoolExecutor.CallerRunsPolicy()
)
);
}
}
用 AOP 拦截并路由执行
基于 Spring AOP（或 AspectJ），拦截带 @ThreadPoolGroup 的方法调用，将原逻辑提交到对应线程池，而非当前线程：
- 切点匹配 execution(* *(..)) && @annotation(threadPoolGroup)
- 获取注解 value，查 ThreadPoolRegistry 得到目标线程池
- 把原方法封装为 Callable/Runnable，submit 到目标池，返回 Future 或 void
- 注意：若原方法有返回值，需同步等待 Future.get()，否则会丢失结果
简单切面示例：
@Aspect
@Component
public class ThreadPoolGroupAspect {
@Around("@annotation(threadPoolGroup)")
public Object routeToPool(ProceedingJoinPoint joinPoint, ThreadPoolGroup threadPoolGroup) throws Throwable {
String group = threadPoolGroup.value();
ThreadPoolExecutor pool = ThreadPoolRegistry.get(group);
<pre class="brush:php;toolbar:false;"> return pool.submit(() -> {
try {
return joinPoint.proceed();
} catch (Throwable t) {
throw new RuntimeException(t);
}
}).get(); // 同步阻塞获取结果；异步场景可返回 Future
}}
进阶：支持异步非阻塞 & 上下文透传
真实业务中常需异步执行且保留 MDC、事务、用户上下文等。此时不能简单 submit 后 get：
- 用 Supplier 封装逻辑，并借助 TransmittableThreadLocal（TTL）传递上下文
- 返回 CompletableFuture，由调用方决定是否 .join() 或 .thenApply()
- 避免在 @Async 方法上再套 @ThreadPoolGroup，防止嵌套线程切换混乱
例如：
return CompletableFuture.supplyAsync(() -> {
// TTL 已自动复制父线程上下文
return (String) joinPoint.proceed();
}, ThreadPoolRegistry.get(group));
不复杂但容易忽略细节：注解生效依赖代理机制（CGLIB/JDK Proxy）、线程池需合理 shutdown、group 名建议统一配置中心管理。真正落地时，建议配合监控（活跃数、队列积压、拒绝率）形成闭环。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
