高性能工业级自动分发器用FutureTask+线程池实现,支持泛型返回、批量超时等待、统一异常处理、熔断取消及资源清理,92行纯JDK代码完成。

用不到 100 行原生 Java 实现高性能、工业级强度的有返回值自动分发器,核心不在堆代码,而在精准控制任务生命周期、避免阻塞、复用资源、统一异常与超时策略。FutureTask 是关键支点——它既是 Runnable 又是 Future,天然支持异步执行 + 结果获取 + 状态管理,无需引入任何第三方库。
用线程池 + FutureTask 构建轻量调度骨架
不手写线程、不裸启 Thread,全部委托给 ThreadPoolExecutor 管理。FutureTask 封装 Callable,提交即返回,立刻获得可轮询/等待/取消的 Future 实例:
- 固定大小线程池(如 CPU 核心数 × 2)平衡吞吐与上下文切换
- 拒绝策略选 CallerRunsPolicy:过载时由调用线程本地执行,自然限流,不丢任务也不 OOM
- 每个分发请求封装为一个 FutureTask<T>,提交后保留 Future 引用,用于后续结果聚合或取消
支持泛型返回值与批量结果聚合
分发器必须知道“要什么类型的结果”,所以主接口定义为 <T> List<Future<T>> dispatch(List<Callable<T>> tasks)。不等单个完成,而是提供非阻塞检查和带超时的批量获取:
- 提供 awaitAll(long timeout, TimeUnit unit):遍历 Future 列表,逐个 get(timeout),任一超时则整体中断并收集已得结果
- 异常统一包装为自定义 DispatchException,含失败索引、原始异常、超时标志,便于下游分类处理
- 结果列表保持与任务入参顺序一致,避免下标错位(FutureTask 不保证执行顺序,但提交顺序可控,结果按 Future 列表顺序取即可)
内置熔断、取消与资源清理机制
工业级不是只管成功,更要防雪崩、可干预、不泄漏:
立即学习“Java免费学习笔记(深入)”;
- dispatch 返回前注册 shutdown hook 或 close() 方法,确保线程池最终 shutdown,避免 JVM 挂起
- 支持外部传入 CancellationSignal(如 AtomicBoolean),在任务执行中定期检测是否被取消,及时退出耗时计算
- 超时发生时,对未完成 Future 调用 cancel(true),中断正在运行的线程(要求任务本身响应中断)
- 拒绝执行新任务前,先尝试 awaitTermination(100, MILLISECONDS),给正在运行的任务缓冲窗口
零依赖、可嵌入、易测的最小实现
完整核心逻辑(含线程池管理、dispatch、awaitAll、close)控制在 92 行以内。无 Spring、无 Guava、无 Lombok,仅 JDK 8+ 原生 API:
- 构造器接收线程池实例(便于复用已有池)或自动创建,解耦资源生命周期
- 所有 public 方法加 @ThreadSafe 注释(Javadoc 级别),明确并发契约
- 单元测试覆盖:并发提交 100 个任务、模拟部分超时、验证取消传播、检查结果顺序 —— 全部用 CountDownLatch + ExecutorService 验证,不依赖测试框架高级特性


















