Java ExecutorService与Future接口如何配合使用

Java中的ExecutorService和Future接口通常配合使用，以便在多线程环境中异步地执行任务并获取结果。下面是如何使用它们的基本步骤：

1. 创建一个实现了Callable接口的任务类。Callable接口类似于Runnable，但它可以返回一个结果，并且可以抛出异常。

import java.util.concurrent.Callable;

public class MyTask implements Callable<Integer> {
    @Override
    public Integer call() throws Exception {
        // 这里是任务的具体实现
        return 42;
    }
}

2. 创建一个ExecutorService实例。通常，我们使用Executors工具类来创建一个线程池。

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

ExecutorService executorService = Executors.newFixedThreadPool(5);

3. 使用ExecutorService提交Callable任务，并获取一个Future对象。

Future<Integer> future = executorService.submit(new MyTask());

4. 使用Future对象的get()方法等待任务完成并获取结果。如果任务尚未完成，get()方法将阻塞，直到任务完成。

try {
    Integer result = future.get(); // 等待任务完成并获取结果
    System.out.println("任务结果是: " + result);
} catch (Exception e) {
    e.printStackTrace();
}

5. 当不再需要ExecutorService时，关闭它以释放资源。

executorService.shutdown();

这是一个完整的示例：

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

public class ExecutorServiceFutureExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        Callable<Integer> task = () -> {
            // 这里是任务的具体实现
            return 42;
        };

        Future<Integer> future = executorService.submit(task);

        try {
            Integer result = future.get(); // 等待任务完成并获取结果
            System.out.println("任务结果是: " + result);
        } catch (Exception e) {
            e.printStackTrace();
        }

        executorService.shutdown();
    }
}

这个示例中，我们创建了一个固定大小的线程池，提交了一个Callable任务，并使用Future对象获取了任务的结果。最后，我们关闭了ExecutorService以释放资源。