如何在Java中使用ThreadPoolExecutor-java教程-PHP中文网

如何在Java中使用ThreadPoolExecutor

P粉602998670

发布： 2025-09-27 10:54:02

原创

271人浏览过

答案：Java中通过ThreadPoolExecutor可自定义核心线程数、最大线程数、任务队列等参数来优化线程管理，使用execute或submit提交任务，需调用shutdown关闭线程池以释放资源。

如何在java中使用threadpoolexecutor

在Java中使用ThreadPoolExecutor可以有效管理线程资源，提升程序性能。它允许你自定义线程池的行为，比如核心线程数、最大线程数、空闲线程存活时间等。下面介绍如何正确创建和使用ThreadPoolExecutor。

创建ThreadPoolExecutor实例

ThreadPoolExecutor提供了多个构造函数，最完整的一个如下：

public ThreadPoolExecutor(
    int corePoolSize,
    int maximumPoolSize,
    long keepAliveTime,
    TimeUnit unit,
    BlockingQueue<Runnable> workQueue,
    ThreadFactory threadFactory,
    RejectedExecutionHandler handler
)

登录后复制

各参数含义如下：

corePoolSize：核心线程数，即使空闲也不会被回收（除非设置了allowCoreThreadTimeOut）
maximumPoolSize：线程池最大线程数
keepAliveTime：非核心线程的空闲存活时间
unit：存活时间的单位，如TimeUnit.SECONDS
workQueue：任务队列，用于存放待执行的任务
threadFactory：创建新线程的工厂，可自定义线程名称等属性
handler：拒绝策略，当任务无法提交时的处理方式

示例代码：

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

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    2,           // 核心线程数
    4,           // 最大线程数
    60L,         // 空闲线程存活时间
    TimeUnit.SECONDS,
    new LinkedBlockingQueue<>(10), // 队列大小
    Executors.defaultThreadFactory(),
    new ThreadPoolExecutor.AbortPolicy() // 拒绝策略
);

登录后复制

提交任务到线程池

你可以通过execute()或submit()方法提交任务。

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

execute(Runnable)：适用于不需要返回值的任务
submit(Runnable)：返回一个Future对象，可用于跟踪任务状态
submit(Callable)：提交有返回值的任务

示例：

// 提交无返回值任务
executor.execute(() -> {
    System.out.println("Task running in " + Thread.currentThread().getName());
});
<p>// 提交有返回值任务
Future<String> future = executor.submit(() -> {
return "Hello from " + Thread.currentThread().getName();
});</p><p>try {
String result = future.get(); // 获取结果
System.out.println(result);
} catch (Exception e) {
e.printStackTrace();
}</p>

登录后复制

关闭线程池

使用完线程池后必须显式关闭，避免资源泄漏。

shutdown()：不再接受新任务，等待已提交任务完成
shutdownNow()：尝试中断正在执行的任务，并返回未执行的任务列表

推荐做法：

executor.shutdown();
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        executor.shutdownNow();
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

登录后复制