ExecutorService提交任务后如何获取结果

在Java中，使用ExecutorService提交任务后，可以通过以下两种方法获取结果：

1. 使用Future对象：

当你使用ExecutorService.submit()方法提交一个实现了Callable接口的任务时，它会返回一个Future对象。你可以通过调用Future对象的get()方法来获取任务的执行结果。get()方法会阻塞，直到任务完成并返回结果。

示例：

import java.util.concurrent.*;

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

        Callable<Integer> task = () -> {
            Thread.sleep(2000);
            return 42;
        };

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

        // 获取任务结果
        Integer result = future.get();
        System.out.println("任务结果: " + result);

        executorService.shutdown();
    }
}

2. 使用CompletionService：

CompletionService是一个接口，它可以将任务的提交和结果的获取分离。你可以使用Executors.newCompletionService()方法创建一个CompletionService实例。然后，你可以使用submit()方法提交任务，并使用take()或poll()方法获取已完成任务的结果。

示例：

import java.util.concurrent.*;

public class Main {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ExecutorService executorService = Executors.newFixedThreadPool(2);
        CompletionService<Integer> completionService = Executors.newCompletionService<>(executorService);

        Callable<Integer> task = () -> {
            Thread.sleep(2000);
            return 42;
        };

        // 提交任务
        completionService.submit(task);

        // 获取已完成任务的结果
        Future<Integer> completedFuture = completionService.take();
        Integer result = completedFuture.get();
        System.out.println("任务结果: " + result);

        executorService.shutdown();
    }
}

这两种方法都可以用于获取ExecutorService提交任务后的结果。Future对象适用于单个任务的场景，而CompletionService适用于多个任务并且需要按完成顺序处理结果的场景。