深入解析 Java Future 类及代码示例

import java.util.concurrent.*;
public class FutureDemo {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        // 提交 Callable 任务
        Future<Integer> future = executor.submit(() -> {
            TimeUnit.SECONDS.sleep(2);
            return 42;
        });
        // 主线程继续执行其他操作
        System.out.println("主线程继续执行其他任务...");
        // 非阻塞检查
        if (!future.isDone()) {
            System.out.println("任务尚未完成，可执行其他操作");
        }
        try {
            // 阻塞获取结果（带3秒超时）
            Integer result = future.get(3, TimeUnit.SECONDS);
            System.out.println("计算结果: " + result);
        } catch (TimeoutException e) {
            System.out.println("计算超时");
            future.cancel(true); // 尝试中断任务
        }
        executor.shutdown();
    }
}

// 当不需要返回有效结果，但需要保留可取消性时
Future<?> future = executor.submit(() -> {
    // 执行任务但不返回有效结果
    performTask();
    return null; // 显式返回 null
});

Future<?> downloadFuture = executor.submit(() -> {
    downloadLargeFile();
    return null; // 无实际返回值，但保留取消能力
});
// 用户取消操作
downloadFuture.cancel(true); // 强制中断下载线程

Future<?> pollingFuture = executor.submit(() -> {
    while (!Thread.interrupted()) {
        pollDatabase();
        Thread.sleep(1000);
    }
    return null;
});
// 设置 30 秒超时
try {
    pollingFuture.get(30, TimeUnit.SECONDS);
} catch (TimeoutException e) {
    pollingFuture.cancel(true); // 超时后终止轮询
}

Future<?> future = executor.submit(() -> {
    try {
        while (!Thread.currentThread().isInterrupted()) {
            // 分阶段任务处理
            processPart1();
            processPart2();
        }
    } finally {
        cleanResources(); // 必须的资源清理
    }
    return null;
});
// 外部取消逻辑
if (needCancel) {
    future.cancel(true); // 触发 finally 块执行
}