FutureTask 是带结果的异步任务载体，封装 Callable 为 Runnable+Future，支持 submit 执行与 get() 获取返回值，适用于需确认任务结果、消费加工后数据及批量聚合分析等场景。
FutureTask 在生产者-消费者模型中不是传统意义上的“队列协调器”，而是作为带结果的异步任务载体，让生产者能提交可返回值的任务，并由消费者（或主线程）按需获取结果。它不替代 BlockingQueue 做缓冲，但能增强任务粒度与结果可控性。
为什么用 FutureTask 而不是普通 Runnable？
普通生产者只发任务、不关心结果；而 FutureTask 将 Callable 封装为 Runnable + Future，既可被线程池执行（兼容 execute），又能通过 get() 获取返回值。这在以下场景很关键：
- 生产者需要确认某次“制作”是否成功完成（比如生成订单号、计算校验码）
- 消费者不直接消费原始数据，而是消费任务执行后的加工结果（如“厨师做完菜后返回菜品ID+时间戳”，而非仅放盘子）
- 多个生产者提交任务后，由统一调度方（如监控线程）批量收集结果做聚合分析
典型配合方式：Callable + FutureTask + 线程池
生产者不再直接 put 到队列，而是构造 Callable 任务，包装成 FutureTask，再 submit 给 ExecutorService：
- 每个 FutureTask 对应一个独立的“可结果化动作”，例如：
new FutureTask<String>(new DishMaker("宫保鸡丁")) - 线程池作为统一执行者（相当于“厨房调度中心”），负责运行这些任务
- 消费者（或主控逻辑）持有 FutureTask 列表，调用
get()阻塞等待完成，或用isDone()/get(timeout)实现超时控制
和传统 BlockingQueue 模型的区别
FutureTask 不维护共享缓冲区，它的“队列语义”体现在线程池的 work-queue 中，本质是任务级异步+结果拉取：
立即学习“Java免费学习笔记（深入）”；
- 传统模型：生产者 → BlockingQueue ← 消费者（数据流驱动）
- FutureTask 模型：生产者 → Executor.submit(task) → 返回 Future ← 消费者调用 get()（任务完成驱动）
- 两者可共存：比如用 BlockingQueue 存放 Future 对象本身（即“任务句柄”），实现更灵活的消费调度
实际使用注意点
避免因误用导致阻塞或资源泄漏：
- 不要在生产者线程里直接调 get()：否则就退化成同步调用，失去异步意义
- 务必处理 ExecutionException：Callable 抛出的异常会被包装，不 catch 会中断后续逻辑
- FutureTask 不可重复执行：run() 成功后 state 变为 FINISHED，再次 run() 无效
- 若需取消，调用
cancel(true)并确保 Callable 内部响应中断（如检查 Thread.interrupted()）
