Java多线程中的Future和Callable接口如何使用

在Java多线程编程中，Future和Callable接口通常一起使用，它们提供了比传统的Thread和Runnable接口更强大的功能。Callable接口允许线程返回一个结果，并且能够抛出异常，而Future接口则用于接收这个结果或者处理异常。

下面是如何使用Callable和Future接口的基本步骤：

1. 实现Callable接口： 创建一个类实现Callable接口，并实现call()方法。call()方法可以返回一个结果，并且可以抛出异常。

import java.util.concurrent.Callable;

public class MyCallable implements Callable<Integer> {
    private int id;

    public MyCallable(int id) {
        this.id = id;
    }

    @Override
    public Integer call() throws Exception {
        // 执行一些计算或任务
        return id * id; // 返回计算结果
    }
}

2. 创建线程池： 使用Executors工具类创建一个线程池。

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

ExecutorService executorService = Executors.newFixedThreadPool(5);

3. 提交Callable任务： 使用线程池的submit()方法提交Callable任务。submit()方法返回一个Future对象，可以用来获取任务的执行结果。

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

4. 获取任务结果： 使用Future对象的get()方法来获取任务的执行结果。如果任务还没有完成，get()方法会阻塞直到任务完成。

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

5. 关闭线程池： 当所有任务都完成后，应该关闭线程池以释放资源。

executorService.shutdown();

下面是一个完整的示例，展示了如何使用Callable和Future接口：

import java.util.concurrent.*;

public class CallableFutureExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 创建并提交多个Callable任务
        Future<Integer> future1 = executorService.submit(new MyCallable(1));
        Future<Integer> future2 = executorService.submit(new MyCallable(2));
        Future<Integer> future3 = executorService.submit(new MyCallable(3));

        // 获取并打印任务结果
        try {
            System.out.println("任务1的结果: " + future1.get());
            System.out.println("任务2的结果: " + future2.get());
            System.out.println("任务3的结果: " + future3.get());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }

        // 关闭线程池
        executorService.shutdown();
    }
}

class MyCallable implements Callable<Integer> {
    private int id;

    public MyCallable(int id) {
        this.id = id;
    }

    @Override
    public Integer call() throws Exception {
        // 模拟一些耗时操作
        Thread.sleep(1000);
        return id * id;
    }
}

在这个示例中，我们创建了一个固定大小的线程池，并提交了三个Callable任务。每个任务都会计算一个数的平方，并返回结果。我们通过Future对象获取这些结果，并在控制台上打印出来。最后，我们关闭了线程池。