Java 的并发类库为开发者提供了丰富的工具来处理多线程编程任务，其中线程池是处理并发任务的重要组成部分。线程池可以有效地管理和复用一组线程，避免频繁创建和销毁线程所带来的开销。Java 标准库中提供了多种类型的线程池实现，每种线程池都有其特定的应用场景。本文将以随笔的形式介绍 JDK 中提供的几种线程池实现，并通过示例代码展示它们的使用方法。
固定大小的线程池
固定大小的线程池通过 Executors.newFixedThreadPool(int nThreads) 方法创建。这种线程池中的线程数量是固定的，一旦创建了 n 个线程，这些线程就会一直存活，除非线程池被关闭。当有新的任务提交到线程池时，这些任务会被放入一个队列中，等待线程池中的线程空闲时来执行。
示例代码
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class FixedThreadPoolExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(5); // 创建一个包含5个线程的线程池
for (int i = 0; i < 10; i++) {
final int taskId = i;
executor.submit(() -> {
System.out.println("Task ID: " + taskId + " is running on thread: " + Thread.currentThread().getName());
try {
Thread.sleep(1000); // 模拟耗时操作
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}
executor.shutdown(); // 关闭线程池
}
}
可缓存线程池
可缓存线程池通过 Executors.newCachedThreadPool() 方法创建。这种线程池的特点是，当线程池中的线程数量超出处理任务所需要的线程数量时，多余的空闲线程会被终止。如果某个线程空闲时间超过 60 秒，那么该线程就会被终止并从线程池中移除。当需要执行新的任务时，如果线程池中有空闲的线程，就直接使用空闲线程；如果没有空闲线程，则创建新的线程。
示例代码
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class CachedThreadPoolExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newCachedThreadPool(); // 创建一个可缓存线程池
for (int i = 0; i < 10; i++) {
final int taskId = i;
executor.submit(() -> {
System.out.println("Task ID: " + taskId + " is running on thread: " + Thread.currentThread().getName());
try {
Thread.sleep(1000); // 模拟耗时操作
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}
executor.shutdown(); // 关闭线程池
}
}
单一线程线程池
单一线程线程池通过 Executors.newSingleThreadExecutor() 方法创建。这种线程池只包含一个线程，因此所有任务都会按照顺序执行。这种线程池非常适合那些需要按顺序处理的任务，例如定时任务或者后台任务队列。
示例代码
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class SingleThreadExecutorExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newSingleThreadExecutor(); // 创建一个单一线程线程池
for (int i = 0; i < 10; i++) {
final int taskId = i;
executor.submit(() -> {
System.out.println("Task ID: " + taskId + " is running on thread: " + Thread.currentThread().getName());
try {
Thread.sleep(1000); // 模拟耗时操作
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}
executor.shutdown(); // 关闭线程池
}
}
定时任务线程池
定时任务线程池通过 Executors.newScheduledThreadPool(int corePoolSize) 方法创建。这种线程池不仅可以执行周期性的任务，还可以在指定的延迟之后执行任务。它非常适合用来处理定时任务。
示例代码
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledThreadPoolExample {
public static void main(String[] args) {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(5); // 创建一个包含5个线程的定时任务线程池
Runnable task = () -> System.out.println("Executing task on thread: " + Thread.currentThread().getName());
// 在5秒后执行任务
executor.schedule(task, 5, TimeUnit.SECONDS);
// 每隔3秒重复执行任务
executor.scheduleAtFixedRate(task, 0, 3, TimeUnit.SECONDS);
// 在5秒后开始执行任务，每隔3秒重复执行
executor.scheduleWithFixedDelay(task, 5, 3, TimeUnit.SECONDS);
// 关闭线程池
executor.shutdown();
}
}
总结
通过上述随笔，我们可以了解到 JDK 中提供了多种类型的线程池实现，每种线程池都有其特定的应用场景。选择合适的线程池类型对于优化并发程序的性能至关重要。无论是创建固定大小的线程池、可缓存线程池、单一线程线程池还是定时任务线程池，都需要根据具体的业务需求来确定。熟悉这些线程池的特点和使用方法，可以帮助我们在开发中更加高效地处理并发任务。无论是在日常开发还是面试准备中，掌握这些知识都是非常重要的。
