当前位置：首页 > Java

java如何使用线程池

2026-03-18 22:19:43Java

线程池的基本概念

线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。线程池可以有效地管理线程的生命周期，减少资源消耗和提高响应速度。

创建线程池

Java中可以通过java.util.concurrent.Executors类提供的静态工厂方法来创建线程池。常见的线程池类型包括：

java如何使用线程池

固定大小线程池：线程数量固定，适用于负载较重的服务器。
可缓存线程池：线程数量根据需求动态调整，适用于执行短期异步任务。
单线程池：只有一个线程的线程池，适用于需要顺序执行任务的场景。
定时任务线程池：适用于需要定期或延迟执行任务的场景。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

// 固定大小线程池
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);

// 可缓存线程池
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

// 单线程池
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

// 定时任务线程池
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

提交任务到线程池

通过ExecutorService的submit或execute方法提交任务。submit方法可以返回Future对象，用于获取任务执行结果或取消任务。

// 使用execute方法提交任务
fixedThreadPool.execute(() -> {
    System.out.println("Task executed by " + Thread.currentThread().getName());
});

// 使用submit方法提交任务并获取Future对象
Future<String> future = fixedThreadPool.submit(() -> {
    return "Task result";
});

关闭线程池

线程池使用完毕后需要关闭以释放资源。可以通过shutdown或shutdownNow方法关闭线程池。

java如何使用线程池

shutdown：平滑关闭线程池，不再接受新任务，但会等待已提交的任务执行完成。
shutdownNow：立即关闭线程池，尝试中断正在执行的任务并返回未执行的任务列表。

// 平滑关闭线程池
fixedThreadPool.shutdown();

// 立即关闭线程池
List<Runnable> unfinishedTasks = fixedThreadPool.shutdownNow();

自定义线程池

如果需要更灵活的配置，可以通过ThreadPoolExecutor类直接创建线程池。可以设置核心线程数、最大线程数、空闲线程存活时间、任务队列等参数。

import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.LinkedBlockingQueue;

int corePoolSize = 5;
int maxPoolSize = 10;
long keepAliveTime = 60;
TimeUnit unit = TimeUnit.SECONDS;
LinkedBlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(100);

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize,
    maxPoolSize,
    keepAliveTime,
    unit,
    workQueue
);

// 提交任务
executor.execute(() -> {
    System.out.println("Custom thread pool task executed");
});

// 关闭线程池
executor.shutdown();

线程池的异常处理

线程池中的任务如果抛出未捕获的异常，默认会打印堆栈信息并终止线程。可以通过自定义ThreadFactory或重写ThreadPoolExecutor的afterExecute方法处理异常。

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    5, 10, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>()
) {
    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        if (t != null) {
            System.err.println("Task failed with exception: " + t.getMessage());
        }
    }
};