Java 中自己的业务方法返回自己的 Feture，如何实现？

在 Java 中，如果想要自己的业务方法返回一个 Future 对象，这通常意味着你希望该方法能够异步地执行某个任务，并且调用者可以稍后检查任务是否完成或获取结果，这可以使用 ExecutorService 和 Future 接口来实现。

ExecutorService 接口

ExecutorService 接口在 Java 多线程编程中非常重要的接口，提供了管理和执行异步任务的方法。它继承自 Executor 接口，并添加了一些更强大的功能。它允许提交一组可返回结果的任务，并提供了方法来等待这些任务的完成、获取已完成任务的结果等。

通过 ExecutorService，可以方便地管理线程池，控制线程的数量和生命周期，提高系统的性能和资源利用率。常用 submit()、execute()、shutdown()、shutdownNow() 等方法来执行任务和管理线程池的状态。

• submit() 方法允许提交一个可返回结果的任务，并返回一个 Future 对象，通过 Future 对象可以获取任务的执行结果或检查任务是否已完成。

• execute () 方法用于提交一个不返回结果的任务。

• shutdown() 方法用于优雅地关闭线程池，它会等待正在执行的任务完成后再关闭线程池。

• shutdownNow() 方法则尝试立即停止所有正在执行的任务，并返回未执行任务的列表。

Future 接口

Future 接口在编程中扮演着重要的角色。它通常用于表示异步操作的结果，允许开发者在不阻塞主线程的情况下执行耗时的任务，并在稍后获取任务的结果。

Future 接口提供了一些方法来检查任务是否已完成、获取任务的结果或者处理任务执行过程中可能出现的异常。通过使用 “Future” 接口，开发者可以更好地管理异步操作，提高程序的响应性和性能。

公共广告位-后端

简单示例

下面是一个简单的示例，说明如何实现这样的业务方法：

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class FutureDemo {

    public static void main(String[] args) throws Exception {
        // 创建线程池
        ExecutorService executorService = Executors.newSingleThreadExecutor();

        // 提交任务，返回一个 Future 对象
        Future<String> future = executorService.submit(new MyBusinessTask("future demo"));

        // 这里你可以做其他事情，直到任务完成
        System.out.println("Waiting for task to complete...");

        // 关闭服务（如果你不再需要它）
        executorService.shutdown();

        // 获取并打印结果
        // 注意：如果任务尚未完成，get() 方法会阻塞
        String result = future.get();
        System.out.println("result=" + result);
        // 输出：
        //Waiting for task to complete...
        //result=Processed: FUTURE DEMO
    }

    /**
     * 业务任务
     * 实现 Callable 接口，表示这是一个可以异步执行的任务，并且它的结果可以被检索
     */
    static class MyBusinessTask implements Callable<String> {
        private final String input;

        public MyBusinessTask(String input) {
            this.input = input;
        }

        // 结果类型为 String
        @Override
        public String call() throws Exception {
            // 在这里处理耗时任务，此处模拟2秒后处理完成
            Thread.sleep(2000);
            return "Processed: " + input.toUpperCase();
        }

    }

}

注意：在上面的示例中，我使用了 Executors.newSingleThreadExecutor() 来创建一个单线程的 ExecutorService。这意味着所有提交给该服务的任务都将在一个单独的线程上顺序执行。根据你的需求，你可以选择使用其他类型的 ExecutorService，例如固定大小的线程池或缓存线程池。