当前位置：首页 > 文章列表 > 文章 > java教程 > Java使用Future获取线程结果详解

Java使用Future获取线程结果详解

2025-12-12 21:29:56 0浏览收藏

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是文章学习者，那么本文《Java如何用Future获取线程结果》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

Future通过Callable和FutureTask或线程池获取异步任务结果，支持阻塞获取、超时控制及任务状态判断，适用于简单异步场景。

在Java中如何使用Future获取线程结果

在Java中，Future 是用于获取异步任务执行结果的一种机制。当你启动一个线程去执行耗时操作时，主线程可以继续做其他事情，等需要结果时再通过 Future 获取。下面介绍如何使用 Future 正确获取线程的执行结果。

使用 Callable 和 FutureTask

与 Runnable 不同，Callable 可以返回结果并抛出异常。将 Callable 提交到线程或线程池后，会得到一个 Future 对象，通过它获取结果。

示例代码：

import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;

public class FutureExample {
    public static void main(String[] args) throws Exception {
        // 定义一个有返回值的任务
        Callable task = () -> {
            Thread.sleep(2000);
            return "任务完成";
        };

        // 包装成 FutureTask
        FutureTask futureTask = new FutureTask<>(task);

        // 启动线程执行任务
        new Thread(futureTask).start();

        // 主线程可以先做别的事
        System.out.println("等待结果中...");

        // 获取结果（阻塞直到任务完成）
        String result = futureTask.get(); 
        System.out.println(result);
    }
}

结合线程池使用 Future

实际开发中更推荐使用 ExecutorService 提交任务，它会直接返回 Future 对象。

示例代码：

import java.util.concurrent.*;

public class FutureWithPool {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newSingleThreadExecutor();

        Callable task = () -> {
            int sum = 0;
            for (int i = 1; i <= 5; i++) {
                sum += i;
                Thread.sleep(500);
            }
            return sum;
        };

        Future future = executor.submit(task);

        System.out.println("任务已提交，正在执行...");

        // 可以设置超时，避免无限等待
        try {
            Integer result = future.get(3, TimeUnit.SECONDS);
            System.out.println("计算结果：" + result);
        } catch (TimeoutException e) {
            System.out.println("任务超时，未完成");
        }

        executor.shutdown();
    }
}