【Java并发编程】了解并合理使用Executors工具类来创建线程池

线程池的概念

线程池是Java中用于管理和复用线程的一种机制，它能够提高多线程程序的性能和资源利用率。线程池的主要概念和组件包括：

线程池的定义：线程池是一组线程的集合，这些线程在执行任务时可以被重复使用，而不是每次任务执行时都创建和销毁线程。这样可以减少线程创建的开销，提高系统的响应速度和吞吐量。
主要组件：
- 核心线程数：线程池中保持活动的最小线程数量。即使在空闲时，这些线程也不会被销毁。
- 最大线程数：线程池所能容纳的最大线程数量。当任务数量超过核心线程数时，会根据需求创建新线程，直到达到最大线程数量。
- 任务队列：用于存放等待执行的任务的队列。常见的队列类型包括有界队列和无界队列。
- 线程工厂：用于创建新线程的工厂，可以自定义线程的属性，以便于管理和调试。
- 拒绝策略：当任务数量超过最大线程数且任务队列已满时，线程池采取的策略，包括抛弃旧任务、抛弃新任务、调用者运行等策略。
使用线程池的好处：
- 降低资源消耗：通过重用线程，减少频繁创建和销毁线程的开销。
- 提高响应速度：任务到达时可以立即执行，不必等到创建线程。
- 方便管理：集中管理线程，有助于监控和调试。
Java中的线程池实现：Java提供了java.util.concurrent包中的Executor框架来创建和管理线程池。最常用的线程池实现是ThreadPoolExecutor，可以通过Executors类方便地创建常用的线程池，例如固定大小线程池、缓存线程池和单线程池等。

总之，线程池是Java并发编程中一个重要的组成部分，通过合理的配置和使用，可以显著提升程序的性能和效率。

创建线程池的方式

在Java中，Executors类提供了多种方便的方法来创建不同类型的线程池。以下是几种常用的线程池创建方式：

1.固定大小线程池：

使用Executors.newFixedThreadPool(int nThreads)创建一个固定大小的线程池，该池包含指定数量的线程。所有提交的任务将在这些线程中执行。

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);

2.缓存线程池：

使用Executors.newCachedThreadPool()创建一个可根据需求创建新线程的线程池。如果线程池中的线程在60秒内未被使用，则会被终止并从池中移除。

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

3.单线程池：

使用Executors.newSingleThreadExecutor()创建一个只包含一个线程的线程池。这个线程池会顺序执行提交的任务，保证任务的执行顺序。

ExecutorService singleThreadPool = Executors.newSingleThreadExecutor();

4.定时任务线程池：

使用Executors.newScheduledThreadPool(int corePoolSize)创建一个支持定时及周期性任务的线程池。这种线程池可以执行延迟任务或周期性任务。

ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

以上是常用的几种通过Executors创建线程池的方式。选择合适类型的线程池可以根据具体的应用场景和需求，以提高程序的性能和可伸缩性。

线程池的使用场景

下面是一个使用线程池的实际场景示例：假设我们需要处理多个下载任务，比如从多个URL下载文件。使用线程池可以有效地管理这些短时间的任务，避免频繁创建和销毁线程。

使用场景：下载文件

场景描述

我们需要下载多个文件，为了提高下载效率，使用线程池来并发处理这些下载任务。

代码示例

import java.io.BufferedInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.URL;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class FileDownloader {private static final String[] FILE_URLS = {"https://example.com/file1.zip","https://example.com/file2.zip","https://example.com/file3.zip",// 添加更多的URL};public static void main(String[] args) {// 创建一个固定大小的线程池ExecutorService downloadPool = Executors.newFixedThreadPool(3);for (String fileUrl : FILE_URLS) {downloadPool.submit(() -> downloadFile(fileUrl));}// 关闭线程池downloadPool.shutdown();}private static void downloadFile(String fileUrl) {String fileName = fileUrl.substring(fileUrl.lastIndexOf("/") + 1);try (BufferedInputStream in = new BufferedInputStream(new URL(fileUrl).openStream());FileOutputStream fileOutputStream = new FileOutputStream(fileName)) {byte dataBuffer[] = new byte[1024];int bytesRead;while ((bytesRead = in.read(dataBuffer, 0, 1024)) != -1) {fileOutputStream.write(dataBuffer, 0, bytesRead);}System.out.println("Downloaded: " + fileName);} catch (IOException e) {System.err.println("Error downloading file: " + fileName);e.printStackTrace();}}
}

代码解释

初始化线程池：我们使用Executors.newFixedThreadPool(3)创建一个固定大小的线程池，设置为3个线程，以便同时下载最多3个文件。
提交下载任务：通过循环遍历FILE_URLS数组，为每个文件URL提交一个下载任务到线程池。
下载方法：downloadFile方法负责下载指定URL的文件，并将其保存到本地。使用BufferedInputStream来读取文件内容，并用FileOutputStream将内容写入本地文件。
关闭线程池：所有任务提交之后，调用shutdown()方法来关闭线程池。这样可以确保所有任务都将在完成后正常退出。

总结

在这个场景中，线程池有效地管理了多个文件下载任务，通过并发执行提高了下载的效率，避免了创建和销毁线程的额外开销。

线程池的模拟实现

下面是一个简单的线程池的实现示例。该示例展示了如何使用底层的Thread类和BlockingQueue来创建一个基本的线程池。

代码示例

import java.util.LinkedList;
import java.util.List;
import java.util.Queue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;class MyThreadPool {private final int numThreads;private final List<Worker> workers;private final BlockingQueue<Runnable> taskQueue;public MyThreadPool(int numThreads) {this.numThreads = numThreads;workers = new LinkedList<>();taskQueue = new LinkedBlockingQueue<>();// 初始化并启动工作线程for (int i = 0; i < numThreads; i++) {Worker worker = new Worker();workers.add(worker);worker.start();}}// 提交任务到线程池public void submit(Runnable task) {taskQueue.offer(task);}// 关闭线程池public void shutdown() {for (Worker worker : workers) {worker.interrupt(); // 请求工作线程停止}}// 工作线程类private class Worker extends Thread {public void run() {while (true) {try {Runnable task = taskQueue.take(); // 获取任务，如果没有则阻塞task.run(); // 执行任务} catch (InterruptedException e) {break; // 线程被中断，退出}}}}public static void main(String[] args) {MyThreadPool threadPool = new MyThreadPool(3); // 创建一个包含3个线程的线程池// 提交多个任务for (int i = 0; i < 10; i++) {final int taskId = i;threadPool.submit(() -> {System.out.println("Executing task " + taskId + " by " + Thread.currentThread().getName());try {Thread.sleep(1000); // 模拟任务执行} catch (InterruptedException e) {Thread.currentThread().interrupt();}});}threadPool.shutdown(); // 关闭线程池}
}

代码解释

类定义：
- MyThreadPool: 自定义线程池类，包含工作线程和任务队列。
- numThreads: 线程池中线程的数量。
- workers: 线程池中工作的线程列表。
- taskQueue: 存储待执行任务的阻塞队列。
构造函数：
- MyThreadPool(int numThreads): 构造函数初始化线程池，创建指定数量的工作线程并启动它们。
提交任务：
- submit(Runnable task): 将任务添加到任务队列中，使用taskQueue.offer(task)方法。
关闭线程池：
- shutdown(): 请求所有工作线程停止，通过调用interrupt()来中断工作线程。
工作线程：
- 内部类Worker继承自Thread，负责从任务队列中获取任务并执行。使用taskQueue.take()方法来阻塞获取任务，直到队列中有任务可用，线程会一直运行，直到被中断。
主方法：
- 在main方法中，创建了一个包含3个线程的线程池，然后提交了10个任务，其中每个任务会在控制台输出其ID并休眠1秒钟来模拟执行。