Java并发编程：线程池的使用实例

原创末蓝、 2024-11-12 08:27 11阅读 0赞

Java并发编程中，线程池是一种执行器（Executor），用于在一个后台线程中执行任务。线程池的主要目的是减少在创建和销毁线程时所产生的性能开销。通过重用已经创建的线程来执行新的任务，线程池提高了程序的响应速度，并且提供了更好的系统资源管理。

以下是使用`java.util.concurrent`包中的`Executors`工厂类来创建线程池的一个简单实例：

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

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

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

// 关闭线程池，不再接受新任务，已提交的任务继续执行 executor.shutdown();

//等待所有任务完成，或者超时 try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
// 超时后终止当前正在执行的任务 executor.shutdownNow();
 }
} catch (InterruptedException ex) {
// 如果等待时被中断，重新设置中断状态Thread.currentThread().interrupt();
//尝试立即关闭线程池 executor.shutdownNow();
 }
 }
}
```在这个例子中，我们创建了一个固定大小为5的线程池，然后提交了10个任务。每个任务简单地打印出它正在被哪个线程执行，并模拟执行了2秒钟。在所有任务提交后，我们调用`shutdown()`方法来关闭线程池，告诉它不再接受新任务，但已提交的任务会继续执行。然后我们调用`awaitTermination()`等待所有任务完成，或者直到超时。如果超时，我们调用`shutdownNow()`尝试立即停止所有正在执行的任务。

这个例子展示了线程池的基本使用方法，实际应用中可以根据需要选择不同类型的线程池，如`CachedThreadPool`、`ScheduledThreadPool`等。