Java如何创建和管理线程池？

Java 线程池创建与管理指南

简介

线程池是一组预先创建的线程，可用于执行并发任务。它提供了一种管理和优化线程使用的机制，提高性能并防止资源耗尽。

创建线程池

使用 Executors 类创建线程池：

ExecutorService threadPool = Executors.newFixedThreadPool(numThreads);

其中 numThreads 是要创建的线程数。

管理线程池

一旦创建了线程池，您可以使用以下方法进行管理：

• 提交任务：使用 submit() 方法提交任务：

Future<Result> future = threadPool.submit(task);

• 关闭线程池：使用 shutdown() 方法关闭线程池，它会等待所有正在运行的任务完成：

threadPool.shutdown();

• 终止线程池：使用 shutdownNow() 方法立即终止线程池，它会尝试中断所有正在运行的任务：

threadPool.shutdownNow();

实战案例

以下代码演示了如何使用线程池处理图像处理任务：

ExecutorService threadPool = Executors.newFixedThreadPool(4);
List<Image> images = ...;  // 获取需处理的图像列表

for (Image image : images) {
    Future<Image> future = threadPool.submit(() -> processImage(image));
}

// 等待所有图像处理完成
for (Future<Image> future : futures) {
    Image processedImage = future.get();
}

在该示例中，线程池最多同时处理 4 张图像。当提交任务时，submit() 方法会返回一个 Future，该 Future 可用于获取任务完成后的结果。

注意事项

• 线程池大小：线程池的大小应根据任务类型和可用资源进行优化。
• 任务依赖性：确保任务之间没有依赖关系，否则可能会导致死锁。
• 资源泄漏：确保关闭所有 Future 对象，以防止资源泄漏。
• 错误处理：submit() 方法会抛出异常，确保捕获这些异常并适当处理。