Java ExecutorService如何与线程池结合使用

Java的ExecutorService是一个用于管理和控制线程的高级接口，它可以与线程池结合使用，以提高系统性能和资源利用率。下面是如何将ExecutorService与线程池结合使用的示例：

1. 导入必要的包：

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

2. 创建一个固定大小的线程池：

int numberOfThreads = 5; // 设置线程池中的线程数量
ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);

3. 提交任务到线程池：

for (int i = 0; i < 10; i++) {
    final int taskNumber = i;
    executorService.submit(() -> {
        System.out.println("Task " + taskNumber + " is executed by thread " + Thread.currentThread().getName());
    });
}

4. 关闭线程池：

在提交完所有任务后，需要关闭线程池。这将导致线程池停止接受新的任务，并开始等待已提交的任务完成。

executorService.shutdown();

5. 等待线程池关闭：

在某些情况下，你可能需要等待线程池完全关闭，以确保所有任务都已完成。可以使用awaitTermination方法来实现这一点。

try {
    if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
        executorService.shutdownNow();
    }
} catch (InterruptedException e) {
    executorService.shutdownNow();
}

将以上代码整合在一起，完整的示例如下：

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

public class ExecutorServiceExample {
    public static void main(String[] args) {
        int numberOfThreads = 5;
        ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);

        for (int i = 0; i < 10; i++) {
            final int taskNumber = i;
            executorService.submit(() -> {
                System.out.println("Task " + taskNumber + " is executed by thread " + Thread.currentThread().getName());
            });
        }

        executorService.shutdown();

        try {
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
                executorService.shutdownNow();
            }
        } catch (InterruptedException e) {
            executorService.shutdownNow();
        }
    }
}

这个示例展示了如何使用ExecutorService创建一个固定大小的线程池，并将任务提交给线程池执行。最后，关闭线程池并等待所有任务完成。