java基础之使用线程池并获取执行结果

import java.util.concurrent.*;
 
public class ThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(4);
        Callable task = () -> {
            Thread.sleep(1000); // 模拟耗时操作
            return "任务完成";
        };
        Future future = executor.submit(task);
        try {
            String result = future.get(); // 获取结果，这会阻塞直到任务完成
            System.out.println(result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            executor.shutdown(); // 关闭线程池
            try {
                if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
                    executor.shutdownNow(); // 如果超时未完成则尝试立即关闭线程池
                }
            } catch (InterruptedException ie) {
                executor.shutdownNow(); // 如果在等待过程中被中断，则尝试立即关闭线程池并恢复中断状态
                Thread.currentThread().interrupt(); // 确保中断状态被设置
            }
        }
    }
}