Java多线 程：如何使用Future和Callable

在Java中，Future和Callable接口通常用于处理异步任务。Callable接口类似于Runnable，但它可以返回一个结果，并且能抛出异常。Future接口表示异步计算的结果，它提供了检查计算是否完成的方法，以等待计算的完成，并检索计算的结果。

下面是如何使用Future和Callable的一个基本示例：

1. 首先，创建一个实现Callable接口的类。这个类需要实现call()方法，该方法将包含异步执行的代码。

import java.util.concurrent.Callable;

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

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

    @Override
    public Integer call() throws Exception {
        // 模拟一个耗时的计算
        Thread.sleep(1000);
        return input * input;
    }
}

2. 接下来，创建一个ExecutorService来管理线程池。

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

public class Main {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(2);
    }
}

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

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

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

        MyCallable myCallable = new MyCallable(5);
        Future<Integer> future = executorService.submit(myCallable);
    }
}

4. 使用Future对象的get()方法等待异步任务完成并获取结果。注意，get()方法可能会阻塞，直到任务完成。

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

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

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

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

5. 最后，关闭ExecutorService。

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

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

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

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

        executorService.shutdown(); // 关闭 ExecutorService
    }
}

这个示例展示了如何使用Future和Callable接口执行异步任务并获取结果。在实际应用中，你可能需要根据具体需求调整代码。