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. 等待線程池關閉：

在某些情況下，你可能需要等待線程池完全關閉，以確保所有任務都已完成?？梢允褂?code>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創建一個固定大小的線程池，并將任務提交給線程池執行。最后，關閉線程池并等待所有任務完成。