使用ExecutorService管理线程池可有效控制并发,避免资源浪费;通过Executors创建FixedThreadPool、CachedThreadPool等线程池,或自定义ThreadPoolExecutor;用submit提交Callable任务获取Future结果,execute执行Runnable任务;最后调用shutdown和awaitTermination安全关闭线程池,防止资源泄漏。

在Java中使用ExecutorService管理线程池,可以有效控制并发任务的执行,避免手动创建和管理线程带来的资源浪费和复杂性。核心思路是通过线程池复用线程、限制并发数量,并统一调度任务。
创建合适的线程池
Java通过Executors工具类提供多种预定义线程池,也可使用ThreadPoolExecutor自定义配置。
- FixedThreadPool:固定大小线程池,适用于负载稳定的任务处理
- CachedThreadPool:可缓存线程池,适合大量短时任务
- SingleThreadExecutor:单线程池,保证任务顺序执行
- Custom ThreadPoolExecutor:灵活控制核心线程数、最大线程数、队列类型等
示例代码:
ExecutorService executor = Executors.newFixedThreadPool(4);
提交任务并处理结果
可以通过execute()或submit()方法提交任务。execute用于无返回值的Runnable,submit支持有返回值的Callable并返回Future对象。
立即学习“Java免费学习笔记(深入)”;
睿拓智能网站系统-睿拓企业网站系统1.2免费版软件大小:6M运行环境:asp+access本版本是永州睿拓信息企业网站管理系统包括了企业网站常用的各种功能,带完整的后台管理系统,本程序无任何功能限制下载即可使用,具体功能如下。1.网站首页2.会员注册3.新闻文章模块4.产品图片展示模块5.人才招聘模块6.在线留言模块7.问卷调查模块8.联系我们模块9.在线QQ客服系统10.网站流量统计系统11.后
- 提交Runnable任务:异步执行无需结果的操作
- 提交Callable任务:获取任务执行结果或异常
- 通过Future.get()阻塞获取结果,注意设置超时避免无限等待
示例:
Futurefuture = executor.submit(() -> { Thread.sleep(1000); return "完成"; }); String result = future.get(); // 获取结果
合理关闭线程池
程序结束前必须显式关闭线程池,防止资源泄漏和JVM无法退出。
推荐步骤:- 调用
shutdown():停止接收新任务,等待已提交任务完成 - 配合
awaitTermination()设置等待时间,确保任务正常结束 - 必要时调用
shutdownNow()强制中断执行中的任务(慎用)
示例:
executor.shutdown();
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow();
}
基本上就这些。掌握线程池的创建、任务提交和安全关闭,就能高效管理并发任务。关键是根据业务场景选择合适的线程池类型和参数,避免资源耗尽或性能瓶颈。









