ExecutorService实现获取线程返回值

获取线程返回值是很常见的需求，可以使用ExecutorService线程池来实现。下面是步骤：

步骤一：创建Callable

Callable是一个带有返回值的线程接口，需要实现其中的call()方法来返回结果。例如，创建一个简单的Callable来计算两个数的和：

import java.util.concurrent.Callable;

public class SumTask implements Callable<Integer> {
    private final int num1;
    private final int num2;

    public SumTask(int num1, int num2) {
        this.num1 = num1;
        this.num2 = num2;
    }

    @Override
    public Integer call() throws Exception {
        Thread.sleep(1000); // 模拟耗时操作
        return num1 + num2;
    }
}

步骤二：提交任务并获取Future

将Callable提交给ExecutorService，并通过返回的Future对象获取结果。Future对象表示一个异步计算的结果，可以使用get()方法来获取结果。

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

public class Main {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        SumTask task = new SumTask(2, 3);
        Future<Integer> future = executor.submit(task);
        Integer result = future.get();
        System.out.println(result);
        executor.shutdown();
    }
}

以上代码中，我们创建了一个新的单线程ExecutorService，并将SumTask提交给它。然后，我们可以使用Future对象来获取计算的结果。调用future.get()方法时，会阻塞直到计算完成并返回计算结果。

输出结果：

5

步骤三：处理异常

在调用future.get()方法时，会抛出InterruptedException和ExecutionException两种异常。InterruptedException表示线程被中断，ExecutionException表示计算抛出了异常。因此，我们需要在处理future.get()方法时处理这两种异常。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class Main {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        SumTask task = new SumTask(2, 3);
        Future<Integer> future = executor.submit(task);
        try {
            Integer result = future.get(200, TimeUnit.MILLISECONDS);
            System.out.println(result);
        } catch (TimeoutException e) {
            System.out.println("计算超时");
        } catch (Exception e) {
            System.out.println("计算异常");
        }
        executor.shutdown();
    }
}

以上代码中，我们使用future.get(200, TimeUnit.MILLISECONDS)方法来获取结果，并指定了超时时间为200毫秒。如果计算完成则返回结果，如果超时则抛出TimeoutException异常。如果计算抛出了异常，则会抛出ExecutionException异常。我们可以在catch块中进行处理。

另外，需要注意的是，在不需要ExecutorService时，应该在程序中显式调用shutdown()方法来关闭线程池，以避免内存泄漏等问题。

总结起来，使用ExecutorService实现获取线程返回值的步骤如下：

1. 创建一个继承Callable的类来封装计算逻辑，实现call()方法。
2. 创建ExecutorService线程池，将Callable对象提交给它，得到Future对象。
3. 使用Future对象的get()方法来获取计算结果，并处理可能出现的异常。