Java中推荐用Executors创建线程池并submit(Callable)实现异步编程，支持返回结果、异常处理及生命周期管理；需按场景选用newFixedThreadPool、newCachedThreadPool、newSingleThreadExecutor或newScheduledThreadPool；Callable通过call()返回结果，submit后获Future对象，用get(超时)安全获取结果并捕获各类异常；务必调用shutdown()与awaitTermination()配合关闭线程池，避免内存泄漏。
Java中用Executors创建线程池，再通过submit(Callable)提交异步任务，是最常用且推荐的异步编程方式之一。它比直接使用Thread更高效、可控，还能统一管理生命周期和获取返回结果。
选择合适的线程池类型
根据业务场景选对线程池很重要，不同构造方法对应不同调度策略：
-
Executors.newFixedThreadPool(n)：固定大小线程池，适合负载稳定、任务数量可预估的场景（如后台定时同步） -
Executors.newCachedThreadPool()：按需创建线程，空闲60秒自动回收，适合大量短时任务（如HTTP请求处理） -
Executors.newSingleThreadExecutor()：单线程顺序执行，保证任务串行，适合日志写入或状态更新等需要顺序性操作 -
Executors.newScheduledThreadPool(n)：支持延迟/周期执行，适合定时任务（如每5秒检查一次健康状态）
定义Callable任务并提交
Callable与Runnable最大区别是能返回结果并抛出受检异常。实现时需重写call()方法：
Callable<String> task = () -> {
Thread.sleep(1000); // 模拟耗时操作
return "任务完成，结果为：" + System.currentTimeMillis();
};
提交后获得Future对象，用于后续获取结果或控制执行：
立即学习“Java免费学习笔记（深入）”；
ExecutorService pool = Executors.newFixedThreadPool(2); Future<String> future = pool.submit(task);
安全获取异步执行结果
Future.get()会阻塞直到任务完成，实际使用要注意超时和异常处理：
- 用
future.get(3, TimeUnit.SECONDS)设置超时，避免无限等待 - 捕获
ExecutionException（任务内部异常）、CancellationException（被取消）、TimeoutException（超时） - 调用
isDone()或isCancelled()可非阻塞判断状态
示例：
try {
String result = future.get(2, TimeUnit.SECONDS);
System.out.println(result);
} catch (TimeoutException e) {
System.err.println("任务超时，已放弃等待");
} catch (ExecutionException e) {
System.err.println("任务执行出错：" + e.getCause());
} catch (InterruptedException e) {
Thread.currentThread().interrupt(); // 恢复中断状态
}
正确关闭线程池释放资源
线程池不关闭会导致JVM无法正常退出，尤其在Web应用或脚本中容易引发内存泄漏：
- 先调用
shutdown()：停止接收新任务，等待已有任务执行完 - 再配合
awaitTermination()等待终止，超时后可考虑shutdownNow()强制中断 - 建议放在
finally块或try-with-resources（自定义AutoCloseable包装）中确保执行
典型关闭模式：
pool.shutdown();
try {
if (!pool.awaitTermination(10, TimeUnit.SECONDS)) {
pool.shutdownNow();
}
} catch (InterruptedException e) {
pool.shutdownNow();
Thread.currentThread().interrupt();
} 
