Java用Callable与FutureTask构建高可用邮件群发系统，关键在于每封邮件可追溯、失败可重试、压力可缓冲、资源不越界：Callable封装带SendResult返回值的任务并捕获异常；FutureTask支持超时控制与状态查询；线程池显式配置有界队列与拒绝策略；ConcurrentHashMap缓存状态并自动重试，提供REST接口与超时告警。

Java用Callable与FutureTask构建高可用邮件群发系统，关键不是堆并发数，而是让每封邮件可追溯、失败可重试、压力可缓冲、资源不越界。

用Callable封装带返回值的邮件任务

Callable比Runnable更适合邮件发送场景，因为每封邮件需要返回发送结果（成功/失败/错误码），便于后续状态更新和重试判断。

• 实现Callable接口，泛型指定返回类型（如SendResult），在call()中调用JavaMail API完成单封邮件发送
• 捕获所有异常（AuthenticationFailedException、MessagingException、IOException等），统一包装进SendResult.failReason字段
• 避免在call()中做耗时初始化（如Session创建），应提前复用SMTP连接池或预热Session对象

用FutureTask管理任务生命周期与结果获取

FutureTask是RunnableFuture实现，既能submit到线程池执行，又能主动get()结果、isDone()查询状态、cancel()中断任务，天然适配邮件超时控制。

deep-java-review

Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...

下载

• 每个邮件任务包装为FutureTask<SendResult>，提交前生成唯一traceId并绑定到任务实例
• 设置固定超时（如30秒）：future.get(30, TimeUnit.SECONDS)，超时后标记为TIMEOUT并触发告警
• 不阻塞主线程——Controller只负责创建并提交FutureTask，立即返回traceId，由后台定时任务轮询未完成的FutureTask

线程池必须手动配置，禁用Executors默认工厂

直接使用Executors.newFixedThreadPool()会引入无界队列，突发流量下内存暴涨甚至OOM。生产环境必须用ThreadPoolExecutor显式构造。

立即学习“Java免费学习笔记（深入）”；

• 核心线程数 = CPU核数 × 1.5～2（例如8核设12），保障基础吞吐不闲置
• 最大线程数 ≤ 20，防止上下文切换开销反噬性能
• 使用有界队列（LinkedBlockingQueue，容量200～500），配合CallerRunsPolicy拒绝策略——队列满时由Web线程自己执行任务，自然限流
• 线程名格式化（如"email-worker-%d"），便于日志追踪和JVM线程分析

状态全程可查，失败自动补救

异步不等于不可控。每封邮件从入队到结束，必须有完整状态闭环。

• 用ConcurrentHashMap<String, EmailStatus>缓存traceId → 状态映射，字段含status（PENDING/SUCCESS/FAILED/TIMEOUT）、sendTime、failReason、retryCount
• FutureTask执行完成后，回调更新EmailStatus；若因网络抖动失败且retryCount < 3，则自动重新submit新FutureTask
• 提供REST接口/mail/status?traceId=xxx，返回结构化JSON供前端展示或运维排查
• 另起独立线程扫描PENDING超30秒的任务，标记TIMEOUT并推送企业微信/钉钉告警