Java并发编程常见问题：ExecutorService关闭示例

原创小鱼儿 2024-09-05 15:51 97阅读 0赞

在Java的并发编程中，`ExecutorService`是用于管理线程池的一个接口。当线程池不再需要时，通常会关闭`ExecutorService`以释放资源。

下面是一个简单的示例，展示如何使用`ExecutorService`并关闭它：

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

public class ExecutorServiceExample {

public static void main(String[] args) {
        // 创建一个线程池，最大线程数为5
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            executor.submit(() -> {
                System.out.println("Task " + i + " is running.");
                try {
                    Thread.sleep(500); // 模拟任务运行时间
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + i + " has finished.");
            });
        }

// 关闭线程池，释放资源
        executor.shutdown();

// 确保所有任务已完成（如果有的话）
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(100); // 暂停检查
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("ExecutorService has been shutdown successfully.");
    }
}
```

这段代码首先创建了一个固定大小的线程池。然后，它提交了一系列任务到线程池中运行。

在所有任务完成后，`executor.shutdown()` 方法被调用来关闭线程池。最后，程序打印一条消息表示服务已成功关闭。