Java中的并发工具库：ThreadPoolExecutor和ScheduledExecutorService案例解析

原创谁践踏了优雅 2024-11-06 18:05 15阅读 0赞

Java中的并发工具库提供了多种工具来帮助开发者处理并发任务，其中`ThreadPoolExecutor`和`ScheduledExecutorService`是两个非常重要的类。下面我将分别对这两个类进行案例解析。

### ThreadPoolExecutor`ThreadPoolExecutor`是一个线程池执行器，用于在一个后台线程中执行每个任务。它提供了一种比手动管理线程更有效的方式来管理多个线程。

**案例解析：**

假设我们有一个任务列表，需要并发执行这些任务。

```javaimport java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadPoolExecutorExample {
 public static void main(String[] args) {
// 创建一个固定大小的线程池ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池 for (int i =0; i <10; i++) {
 final int taskId = i;
 executor.submit(() -> {
 System.out.println("Executing task " + taskId + " by thread " + Thread.currentThread().getName());
 try {
//模拟任务执行时间 TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
 }
 });
 }

// 关闭线程池 executor.shutdown();
 }
}
```在这个例子中，我们创建了一个固定大小为5的线程池，并提交了10个任务。每个任务在执行时会打印出当前任务ID和执行任务的线程名称，然后休眠1秒模拟任务执行。

### ScheduledExecutorService`ScheduledExecutorService`是一个用于延迟执行或定期执行任务的线程池。

**案例解析：**

假设我们需要定期执行一个任务，比如每隔5秒打印一次当前时间。

```javaimport java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledExecutorServiceExample {
 public static void main(String[] args) {
// 创建一个单线程的ScheduledExecutorService ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();

//定期执行任务，初始延迟1秒，之后每隔5秒执行一次 executor.scheduleAtFixedRate(() -> {
 System.out.println("Current time: " + System.currentTimeMillis());
},1,5, TimeUnit.SECONDS);

//让主线程休眠10秒，以便观察任务执行 try {
 TimeUnit.SECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
 }

// 关闭ScheduledExecutorService executor.shutdown();
 }
}
```在这个例子中，我们创建了一个单线程的`ScheduledExecutorService`，并使用`scheduleAtFixedRate`方法定期执行任务。任务是打印当前时间，初始延迟1秒，之后每隔5秒执行一次。主线程休眠10秒以便观察任务执行，然后关闭`ScheduledExecutorService`。

这两个类提供了强大的并发处理能力，可以帮助我们更高效地管理线程和执行并发任务。