答案:Java中通过ThreadPoolExecutor可自定义核心线程数、最大线程数、任务队列等参数来优化线程管理,使用execute或submit提交任务,需调用shutdown关闭线程池以释放资源。
在Java中使用ThreadPoolExecutor可以有效管理线程资源,提升程序性能。它允许你自定义线程池的行为,比如核心线程数、最大线程数、空闲线程存活时间等。下面介绍如何正
确创建和使用ThreadPoolExecutor。
ThreadPoolExecutor提供了多个构造函数,最完整的一个如下:
public ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler
)
各参数含义如下:
示例代码:
ThreadPoolExecutor executor = new ThreadPoolExecutor(
2, // 核心线程数
4, // 最大线程数
60L, // 空闲线程存活时间
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(10), // 队列大小
Executors.defaultThreadFactory(),
new ThreadPoolExecutor.AbortPolicy() // 拒绝策略
);
你可以通过execute()或submit()方法提交任务。
Future对象,可用于跟踪任务状态示例:
// 提交无返回值任务
executor.execute(() -> {
System.out.println("Task running in " + Thread.currentThread().getName());
});
// 提交有返回值任务
Future future = executor.submit(() -> {
return "Hello from " + Thread.currentThread().getName();
});
try {
String result = future.get(); // 获取结果
System.out.println(result);
} catch (Exception e) {
e.printStackTrace();
}
使用完线程池后必须显式关闭,避免资源泄漏。
推荐做法:
executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow();
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
根据任务类型选择合适的线程池参数:
LinkedBlockingQueue时注意队列可能无限增长,建议指定容量ThreadFactory以便排查问题基本上就这些。合理使用ThreadPoolExecutor能显著提升应用并发能力,同时避免频繁创建线程带来的开销。关键是根据实际场景调整参数,并记得及时关闭资源。不复杂但容易忽略细节。