并发编程：Java中的线程池和 executor服务是如何使用的？

原创 ╰半橙微兮° 2024-09-21 08:03 37阅读 0赞

在Java中，线程池（ThreadPool）和Executor服务是用于管理和复用多线程的工具。以下是这两种方式的基本使用方法：

1. 线程池（ThreadPoolExecutor）

线程池提供了一种预配置了多个线程的机制。以下是一个创建并使用线程池的例子：

```java
// 创建一个固定大小为10的线程池
 ThreadPoolExecutor executor = new ThreadPoolExecutor(10,  // 核心线程数
        TimeUnit.MILLISECONDS, // 时间单位
        new LinkedBlockingQueue<Runnable>())); // 工作队列

// 提交任务到线程池，这里使用匿名内部类作为任务对象
executor.execute(new Runnable() {
    @Override
    public void run() {
        // 这里是你需要在多线程环境下执行的任务
        System.out.println("Task executed by a thread from the pool");
    }
}));

// 关闭线程池，但所有提交的任务会继续运行
executor.shutdown();

// 确保所有任务已经完成并移除队列
while (!executor.isTerminated()) {
    try {
        Thread.sleep(100); // 每秒检查一次
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}
```

2. Executor服务（Executors）

Java提供了一个名为Executors的类，它包含了一些预配置好的线程池。以下是使用Executor服务的一些基本示例：

```java
// 创建一个单线程的线程池
ThreadPoolExecutor executor = Executors.newSingleThreadExecutor();

// 提交任务到线程池
executor.execute(new Runnable() {
    @Override
    public void run() {
        // 这里是你需要在多线程环境下执行的任务
        System.out.println("Task executed by a single thread");
    }
}));

// 关闭线程池，但所有提交的任务会继续运行
executor.shutdown();

总的来说，线程池和Executor服务为Java应用程序提供了更高效、可复用的多线程管理方式。