Java 如何创建和使用ExecutorService

// 创建一个固定大小的线程池，最多同时执行两个任务
ExecutorService executor = Executors.newFixedThreadPool(2);
// 提交两个任务给线程池执行
executor.submit(() -> {
    System.out.println("任务1 正在执行...");
    // 这里放置任务1的具体代码逻辑
});
executor.submit(() -> {
    System.out.println("任务2 正在执行...");
    // 这里放置任务2的具体代码逻辑
});
// 关闭线程池
executor.shutdown();

// 创建一个包含5个线程的固定大小线程池
ExecutorService executor = Executors.newFixedThreadPool(5); 

// 创建一个可根据需要自动扩展的线程池
ExecutorService executor = Executors.newCachedThreadPool(); 

executor.submit(() -> {
    System.out.println("执行任务1");
    // 这里放置任务1的具体代码逻辑
});

Future<Integer> future = executor.submit(() -> {
    System.out.println("执行任务2");
    // 这里放置任务2的具体代码逻辑
    // 返回任务执行结果
    return fu;  
});
try {
    // 获取任务执行结果，可能会阻塞直到任务完成
    Integer result = future.get();  
    System.out.println("任务2 的结果是：" + result);
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

// 等待 200 毫秒
String result = future.get(200, TimeUnit.MILLISECONDS);

// 平稳关闭线程池，等待所有任务执行完成
executor.shutdown(); 

public static void main(String[] args) {
        // 创建一个固定大小为3的线程池
        ExecutorService executor = Executors.newFixedThreadPool(3);
        // 创建一个列表来保存提交的任务
        List<Future<Integer>> futures = new ArrayList<>();
        // 提交10个任务，每个任务返回任务ID乘以2的结果
        for (int i = 1; i <= 10; i++) {
            final int taskId = i;
            // 提交 Callable 任务，并将 Future 对象保存到列表中
            Future<Integer> future = executor.submit(() -> {
                System.out.println("任务 " + taskId + " 开始执行");
                // 模拟任务执行耗时
                Thread.sleep(2000);  
                // 返回任务的结果
                return taskId * 2;   
            });
            // 将 Future 对象添加到列表中
            futures.add(future);  
        }
        // 等待所有任务完成，并打印各任务的执行结果
        for (Future<Integer> future : futures) {
            try {
                // 获取任务执行结果，可能会阻塞直到任务完成
                Integer result = future.get();  
                System.out.println("任务结果: " + result);
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }
        // 关闭线程池
        executor.shutdown();
    }
// 输出结果
任务 1 开始执行
任务 2 开始执行
任务 3 开始执行
任务结果: 2
任务结果: 4
任务 4 开始执行
任务结果: 6
任务 5 开始执行
任务结果: 8
任务 6 开始执行
任务结果: 10
任务 7 开始执行
任务结果: 12
任务 8 开始执行
任务结果: 14
任务 9 开始执行
任务结果: 16
任务 10 开始执行
任务结果: 18
任务结果: 20