在Java中如何使用Future获取线程结果-java教程-PHP中文网

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

P粉602998670

发布： 2025-10-18 22:53:58

原创

438人浏览过

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

在java中如何使用future获取线程结果

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

使用 Callable 和 FutureTask

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

示例代码：

import java.util.concurrent.Callable;<br>import java.util.concurrent.FutureTask;<br><br>public class FutureExample {<br>    public static void main(String[] args) throws Exception {<br>        // 定义一个有返回值的任务<br>        Callable<String> task = () -> {<br>            Thread.sleep(2000);<br>            return "任务完成";<br>        };<br><br>        // 包装成 FutureTask<br>        FutureTask<String> futureTask = new FutureTask<>(task);<br><br>        // 启动线程执行任务<br>        new Thread(futureTask).start();<br><br>        // 主线程可以先做别的事<br>        System.out.println("等待结果中...");<br><br>        // 获取结果（阻塞直到任务完成）<br>        String result = futureTask.get(); <br>        System.out.println(result);<br>    }<br>}

登录后复制

结合线程池使用 Future

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

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

示例代码：

import java.util.concurrent.*;<br><br>public class FutureWithPool {<br>    public static void main(String[] args) throws Exception {<br>        ExecutorService executor = Executors.newSingleThreadExecutor();<br><br>        Callable<Integer> task = () -> {<br>            int sum = 0;<br>            for (int i = 1; i <= 5; i++) {<br>                sum += i;<br>                Thread.sleep(500);<br>            }<br>            return sum;<br>        };<br><br>        Future<Integer> future = executor.submit(task);<br><br>        System.out.println("任务已提交，正在执行...");<br><br>        // 可以设置超时，避免无限等待<br>        try {<br>            Integer result = future.get(3, TimeUnit.SECONDS);<br>            System.out.println("计算结果：" + result);<br>        } catch (TimeoutException e) {<br>            System.out.println("任务超时，未完成");<br>        }<br><br>        executor.shutdown();<br>    }<br>}

登录后复制