Java 并发编程中如何使用 Future 和 Callable 进行异步编程？-java教程-PHP中文网

使用 future 和 callable 进行 java 异步编程：future 封装异步操作的结果，通过 get() 方法获取返回值。callable 用于创建异步任务，类似于 runnable 但可返回值。示例中，创建了一个 callable 任务，提交给执行器服务异步执行。主线程继续执行其他任务，当需要结果时，调用 future.get() 获取。最终关闭执行器服务以释放资源。

Java 并发编程中如何使用 Future 和 Callable 进行异步编程？

使用 Future 和 Callable 进行 Java 并发编程中的异步编程

引言

异步编程是一种允许并发执行任务而不阻塞主线程的技术。在 Java 中，可以使用 Future 和 Callable 接口来实现异步编程。

Future

Future 是一个异步操作的结果封装。它用于获取任务的返回值，即使任务尚未完成。Future 提供了 get() 方法，当任务完成时，它将返回结果。

java-api-doc-generator

分析 Java Spring Boot 后端 Controller 代码，自动生成 Markdown 格式的接口文档。当用户说“生成 Java 接口文档”、“生成 API 文档”、“从 Spring 代码生成文档”时触发。

下载

Callable

Callable 是一个用于创建异步任务的接口。它与 Runnable 接口类似，但是 Callable 可以返回一个值，而 Runnable 只能执行一个操作。

异步编程示例

下面是一个使用 Future 和 Callable 进行异步编程的示例：

import java.util.concurrent.*;

public class AsyncExample {

    public static void main(String[] args) {

        ExecutorService executorService = Executors.newSingleThreadExecutor();

        // 创建 Callable 任务，它将执行一个耗时的操作并返回结果
        Callable<integer> task = () -> {
            // 模拟耗时的任务
            Thread.sleep(1000);
            return 42;
        };

        // 将 Callable 任务提交到执行器服务，它将异步执行任务
        Future<integer> future = executorService.submit(task);

        // 主线程可以继续执行其他任务，而不必等待 Callable 任务完成
        System.out.println("Main thread is doing other work.");

        // 当需要结果时，可以调用 Future 的 get() 方法来获取它
        try {
            // 等待任务完成并获取结果
            Integer result = future.get();
            System.out.println("Result: " + result);
        } catch (InterruptedException | ExecutionException e) {
            // 处理任务中断或执行异常
            e.printStackTrace();
        } finally {
            // 关闭执行器服务以释放资源
            executorService.shutdown();
        }
    }
}</integer></integer>

在这个示例中：