Java - 线程池

大家好，未来的Java开发者们！今天，我们将深入探讨线程池的精彩世界。如果你是编程新手，不用担心；我会一步一步引导你理解这个概念，就像我在过去多年的教学中对无数学生所做的那样。所以，拿一杯咖啡（或者如果你喜欢的话，茶也可以），让我们开始吧！

Java - Thread Pools

什么是线程池？

想象一下你经营着一家繁忙的餐厅。每当有新顾客进来，你可以雇佣一个新的服务员来为他们服务。但那样会混乱且成本高昂！相反，你有一固定数量的服务员为多个顾客服务。这实质上就是线程池在Java编程中所做的。

线程池是一组预先实例化、可重用的线程，它们可以用来执行任务。我们不是为每个任务创建一个新的线程，这样做可能会消耗大量资源，而是使用一组现有的线程来执行这些任务。

为什么在Java中使用线程池？

你可能会想，“为什么要麻烦使用线程池？我们不能在需要的时候直接创建新线程吗？”好吧，让我通过一个教学经历中的小故事来解释。

曾经，我有一个学生试图在他的应用程序中为每个任务创建一个新的线程。他的程序在处理小数据集时运行得很好，但是当他尝试处理大量数据时，他的计算机几乎崩溃了！这就是我向他介绍线程池的时候。

以下是使用线程池的一些关键原因：

更好的性能：创建和销毁线程是昂贵的。线程池通过重用线程来节省开销。
资源管理：你可以控制可以同时运行的最大线程数。
提高响应性：任务可以立即由正在运行的线程执行。

在Java中创建线程池

Java通过Executors类提供了几种创建线程池的方法。让我们看看三种常见的方法：

1. 使用newFixedThreadPool()方法创建线程池

此方法创建一个具有固定数量线程的线程池。让我们看一个例子：

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

public class FixedThreadPoolExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(5);

for (int i = 0; i < 10; i++) {
Runnable worker = new WorkerThread("" + i);
executor.execute(worker);
}

executor.shutdown();
while (!executor.isTerminated()) {
}
System.out.println("所有线程执行完毕");
}
}

class WorkerThread implements Runnable {
private String message;

public WorkerThread(String s) {
this.message = s;
}

public void run() {
System.out.println(Thread.currentThread().getName() + " (开始) 消息 = " + message);
processMessage();
System.out.println(Thread.currentThread().getName() + " (结束)");
}

private void processMessage() {
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

在这个例子中，我们创建了一个具有5个线程的固定线程池。然后我们向这个池提交了10个任务。池将使用其5个线程来执行这10个任务，当线程可用时将重用它们。

2. 使用newCachedThreadPool()方法创建线程池

此方法创建一个根据需要创建新线程的线程池，但如果有可用的先前构建的线程，则会重用它们。让我们看看它是如何工作的：

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 < 100; i++) {
executor.execute(new Task());
}

executor.shutdown();
}
}

class Task implements Runnable {
public void run() {
System.out.println("线程名称: " + Thread.currentThread().getName());
}
}

在这个例子中，我们创建了一个缓存线程池，并向其中提交了100个任务。池将在需要时创建新线程，并在可能的情况下重用它们。

3. 使用newScheduledThreadPool()方法创建线程池

此方法创建一个可以安排在给定延迟后运行命令，或者定期执行的线程池。以下是一个例子：

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(1);

Runnable task = () -> System.out.println("在 " + System.nanoTime() + " 执行任务");

executor.scheduleAtFixedRate(task, 0, 2, TimeUnit.SECONDS);
}
}

在这个例子中，我们创建了一个具有一个线程的计划线程池。然后我们安排一个任务每2秒运行一次。

ExecutorService中的方法

以下是ExecutorService接口中的一些重要方法：

方法	描述
`execute(Runnable)`	在未来的某个时间执行给定的命令
`submit(Callable)`	提交一个返回值的任务以供执行，并返回一个Future
`shutdown()`	启动一个有序的关闭，在此过程中先前的任务将被执行，但不会接受新的任务
`shutdownNow()`	尝试停止所有正在执行的任务，并停止处理等待的任务
`isShutdown()`	如果此执行器已关闭，则返回true
`isTerminated()`	如果关闭后所有任务都已完成，则返回true

结论

好了，各位！我们已经穿越了Java线程池的领域，从理解它们为什么有用到以不同的方式创建和使用它们。记住，就像我们的餐厅比喻一样，线程池帮助我们高效地管理资源。

在我的教学岁月中，我看到了学生们从挣扎于基本的线程概念到构建复杂的、高效的多线程应用程序。通过实践和耐心，你们也会达到这个水平！

在你们的Java之旅中，继续探索和实验。线程池只是Java为并发编程提供的庞大工具集中的一种工具。祝编码愉快，愿你的线程始终高效地池化！

Credits: Image by storyset