import java.util.concurrent.*;  
public class ThreadPoolExample {  
    public static void main(String[] args) throws InterruptedException {  
        // 創(chuàng)建一個(gè)包含固定數(shù)量線程的線程池  
        ExecutorService executorService = Executors.newFixedThreadPool(4);  
        // 定義任務(wù)數(shù)量  
        int taskCount = 10;  
        // 使用CountDownLatch來等待所有任務(wù)完成  
        final CountDownLatch latch = new CountDownLatch(taskCount);  
        // 提交任務(wù)到線程池  
        for (int i = 0; i < taskCount; i++) {  
            int taskId = i;  
            executorService.submit(() -> {  
                // 模擬任務(wù)執(zhí)行  
                try {  
                    Thread.sleep(1000); // 假設(shè)每個(gè)任務(wù)需要1秒  
                } catch (InterruptedException e) {  
                    Thread.currentThread().interrupt();  
                }  
                System.out.println("任務(wù) " + taskId + " 完成");  
                // 每完成一個(gè)任務(wù)，計(jì)數(shù)減一  
                latch.countDown();  
            });  
        }  
        // 等待所有任務(wù)完成  
        System.out.println("等待所有任務(wù)完成...");  
        latch.await(); // 阻塞當(dāng)前線程，直到latch的計(jì)數(shù)達(dá)到零  
        System.out.println("所有任務(wù)完成！");  
        // 關(guān)閉線程池  
        executorService.shutdown();  
        // 可選：等待線程池中的線程都執(zhí)行完畢  
        try {  
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {  
                // 線程池沒有在規(guī)定時(shí)間內(nèi)關(guān)閉，則強(qiáng)制關(guān)閉  
                executorService.shutdownNow();  
            }  
        } catch (InterruptedException e) {  
            // 當(dāng)前線程在等待過程中被中斷  
            executorService.shutdownNow();  
            Thread.currentThread().interrupt();  
        }  
    }  
}

import java.util.ArrayList;  
import java.util.List;  
import java.util.concurrent.*;  
public class ThreadPoolFutureExample {  
    public static void main(String[] args) throws InterruptedException, ExecutionException {  
        // 創(chuàng)建一個(gè)包含固定數(shù)量線程的線程池  
        ExecutorService executorService = Executors.newFixedThreadPool(4);  
        // 創(chuàng)建一個(gè)Callable任務(wù)列表  
        List<Callable<String>> tasks = new ArrayList<>();  
        for (int i = 0; i < 10; i++) {  
            final int taskId = i;  
            tasks.add(() -> {  
                // 模擬任務(wù)執(zhí)行  
                Thread.sleep(1000); // 假設(shè)每個(gè)任務(wù)需要1秒  
                return "任務(wù) " + taskId + " 完成";  
            });  
        }  
        // 使用invokeAll提交所有任務(wù)，這將返回一個(gè)Future列表  
        List<Future<String>> futures = executorService.invokeAll(tasks);  
        // 遍歷Future列表，獲取每個(gè)任務(wù)的結(jié)果  
        for (Future<String> future : futures) {  
            // get()會(huì)阻塞，直到對(duì)應(yīng)的任務(wù)完成  
            System.out.println(future.get());  
        }  
        // 關(guān)閉線程池  
        executorService.shutdown();  
        // 可選：等待線程池中的線程都執(zhí)行完畢  
        try {  
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {  
                // 線程池沒有在規(guī)定時(shí)間內(nèi)關(guān)閉，則強(qiáng)制關(guān)閉  
                executorService.shutdownNow();  
            }  
        } catch (InterruptedException e) {  
            // 當(dāng)前線程在等待過程中被中斷  
            executorService.shutdownNow();  
            Thread.currentThread().interrupt();  
        }  
    }  
}  
// 注意：這里使用了Lambda表達(dá)式和方法引用來簡(jiǎn)化Callable的創(chuàng)建  
// 實(shí)際使用中，你可能需要實(shí)現(xiàn)Callable接口或使用匿名內(nèi)部類

import java.util.ArrayList;  
import java.util.List;  
import java.util.concurrent.*;  
public class ThreadPoolFutureCompleteExample {  
    public static void main(String[] args) {  
        // 創(chuàng)建一個(gè)包含固定數(shù)量線程的線程池  
        ExecutorService executorService = Executors.newFixedThreadPool(4);  
        // 創(chuàng)建一個(gè)Callable任務(wù)列表  
        List<Callable<String>> tasks = new ArrayList<>();  
        for (int i = 0; i < 10; i++) {  
            final int taskId = i;  
            tasks.add(new Callable<String>() {  
                @Override  
                public String call() throws Exception {  
                    // 模擬任務(wù)執(zhí)行  
                    TimeUnit.SECONDS.sleep(1); // 假設(shè)每個(gè)任務(wù)需要1秒  
                    return "任務(wù) " + taskId + " 完成";  
                }  
            });  
            // 或者使用Lambda表達(dá)式（如果你使用的是Java 8或更高版本）  
            // tasks.add(() -> {  
            //     TimeUnit.SECONDS.sleep(1);  
            //     return "任務(wù) " + taskId + " 完成";  
            // });  
        }  
        try {  
            // 使用invokeAll提交所有任務(wù)，這將返回一個(gè)Future列表  
            List<Future<String>> futures = executorService.invokeAll(tasks);  
            // 遍歷Future列表，獲取每個(gè)任務(wù)的結(jié)果  
            for (Future<String> future : futures) {  
                // get()會(huì)阻塞，直到對(duì)應(yīng)的任務(wù)完成  
                System.out.println(future.get());  
            }  
            // 關(guān)閉線程池  
            executorService.shutdown();  
            // 等待線程池中的所有線程都執(zhí)行完畢（可選）  
            // 注意：由于我們已經(jīng)調(diào)用了invokeAll并等待了所有Future的完成，這一步通常是多余的  
            // 但為了完整性，我還是展示了如何等待線程池關(guān)閉  
            boolean terminated = executorService.awaitTermination(60, TimeUnit.SECONDS);  
            if (!terminated) {  
                // 如果線程池沒有在規(guī)定時(shí)間內(nèi)關(guān)閉，則強(qiáng)制關(guān)閉  
                System.err.println("線程池沒有在規(guī)定時(shí)間內(nèi)關(guān)閉，嘗試強(qiáng)制關(guān)閉...");  
                executorService.shutdownNow();  
                // 注意：shutdownNow()不保證已經(jīng)提交的任務(wù)會(huì)被取消  
                // 它會(huì)嘗試停止正在執(zhí)行的任務(wù)，但已經(jīng)開始執(zhí)行的任務(wù)可能無法被中斷  
            }  
        } catch (InterruptedException | ExecutionException e) {  
            // 處理異常  
            e.printStackTrace();  
            // 如果當(dāng)前線程在等待過程中被中斷，嘗試關(guān)閉線程池  
            if (!executorService.isShutdown()) {  
                executorService.shutdownNow();  
            }  
            // 根據(jù)需要，可能還需要重新設(shè)置中斷狀態(tài)  
            Thread.currentThread().interrupt();  
        }  
    }  
}