JAVA 线程池之Callable返回结果

今天药忘吃喽~ 2022-11-07 13:18 223阅读 0赞

本文介绍如何向线程池提交任务，并获得任务的执行结果。然后模拟 线程池中的线程在执行任务的过程中抛出异常时，该如何处理。

**一，执行具体任务的线程类**

要想 获得 线程的执行结果，需实现Callable接口。FactorialCalculator 计算 number的阶乘，具体实现如下：

import java.util.concurrent.Callable;
    import java.util.concurrent.TimeUnit;
    
    /**
     * Created by Administrator on 2017/9/26.
     */
    public class FactorialCalculator implements Callable<Integer> {
    
        private Integer number;
    
        public FactorialCalculator(Integer number) {
            this.number = number;
        }
        public Integer call() throws Exception {
            int result = 1;
    
            if (number == 0 || number == 1) {
                result = 1;
            }else {
                for (int i = 2; i < number; i++) {
                    result *= i;
                    TimeUnit.MICROSECONDS.sleep(200);
                    if (i == 5) {
                        throw new IllegalArgumentException("excepion happend");//计算5以上的阶乘都会抛出异常. 根据需要注释该if语句
                    }
                }
            }
            System.out.printf("%s: %d\n", Thread.currentThread().getName(), result);
            return result;
        }
    }

上面23行--25行的if语句表明：如果number大于5，那么 if(i==5)成立，会抛出异常。即模拟  执行5 以上的阶乘时，会抛出异常。

**二，提交任务的Main类**

下面来看看，怎样向线程池提交任务，并获取任务的返回结果。我们一共向线程池中提交了10个任务，因此创建了一个ArrayList保存每个任务的执行结果。

第一行，首先创建一个线程池。第二行，创建List保存10个线程的执行结果 所要存入的地方，每个任务是计算阶乘，因此线程的返回结果是 Integer。而这个结果只要计算出来了，是放在Future<Integer>里面。

第5-7行，随机生成一个10以内的整数，然后创建一个 FactorialCalculator对象，该对象就是待执行的任务，然后在第8行 通过线程池的submit方法提交。

ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newCachedThreadPool();
            List<Future<Integer>> resultList = new ArrayList<Future<Integer>>();
            Random random = new Random();
            for (int i = 0; i < 10; i ++) {
                int rand = random.nextInt(10);
    
                FactorialCalculator factorialCalculator = new FactorialCalculator(rand);
                Future<Integer> res = executor.submit(factorialCalculator);//异步提交, non blocking.
                resultList.add(res);
            }

需要注意的是：submit方法是个非阻塞方法，[参考这篇文章][Link 1]。提交了任务后，由线程池里面的线程负责执行该任务，执行完成后得到的结果最终会保存在 Future<Integer>里面，正如第8行所示。

As soon as we invoke the submit() method of ExecutorService the Callable are handed over to ExecutorService to execute.
     Here one thing we have to note, the submit() is not blocking. 
    So, all of our Callables will be submitted right away to the ExecutorService, and ExecutorService will decide when to execute which callable. 
    For each Callable we get a Future object to get the result later.

接下来，我们在do循环中，检查任务的状态---是否执行完成。

do {
    //            System.out.printf("number of completed tasks: %d\n", executor.getCompletedTaskCount());
                for (int i = 0; i < resultList.size(); i++) {
                    Future<Integer> result = resultList.get(i);
                    System.out.printf("Task %d : %s \n", i, result.isDone());
                }
                try {
                    TimeUnit.MILLISECONDS.sleep(50);
    
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            } while (executor.getCompletedTaskCount() < resultList.size());

第3-6行for循环，从ArrayList中取出 每个 Future<Integer>，查看它的状态 isDone() ，即：是否执行完毕。

第13行，while结束条件：当所有的线程的执行完毕时，就退出do循环。注意：当线程在执行过程中抛出异常了，也表示线程执行完毕。

**获取线程的执行结果**

System.out.println("Results as folloers:");
            for (int i = 0; i < resultList.size(); i++) {
                Future<Integer> result = resultList.get(i);
                Integer number = null;
    
                try {
                    number = result.get();// blocking method
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (ExecutionException e) {
                    e.printStackTrace();
                }
                System.out.printf("task: %d, result %d:\n", i, number);
            }

第3行取出每个存储结果的地方：Future<Integer>，第7行 从Future<Integer>中获得任务的执行结果。**Future.get方法是一个阻塞方法**。但前面的do-while循环里面，我们已经检查了任务的执行状态是否完成，因此这里能够很快地取出任务的执行结果。

We are invoking the get() method of Future to get the result. Here we have to remember that, the get() is a blocking method.

任务在执行过程中，若抛出异常，下面语句在获取执行结果时会直接跳到catch(ExecutionException e)中。

number = result.get()

![6bad4920fa8b49f79d2b9187809f5555.png][]

但它不影响Main类线程---主线程的执行。

![ad35e9982d5284967b869c81df160655.png][]

整个Main类代码如下：

import java.util.ArrayList;
    import java.util.List;
    import java.util.Random;
    import java.util.concurrent.*;
    
    /**
     * Created by Administrator on 2017/9/26.
     */
    public class Main {
    
        public static void main(String[] args) {
            ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newCachedThreadPool();
            List<Future<Integer>> resultList = new ArrayList<Future<Integer>>();
            Random random = new Random();
            for (int i = 0; i < 10; i ++) {
                int rand = random.nextInt(10);
    
                FactorialCalculator factorialCalculator = new FactorialCalculator(rand);
                Future<Integer> res = executor.submit(factorialCalculator);//异步提交, non blocking.
                resultList.add(res);
            }
    
            // in loop check out the result is finished
            do {
    //            System.out.printf("number of completed tasks: %d\n", executor.getCompletedTaskCount());
                for (int i = 0; i < resultList.size(); i++) {
                    Future<Integer> result = resultList.get(i);
                    System.out.printf("Task %d : %s \n", i, result.isDone());
                }
                try {
                    TimeUnit.MILLISECONDS.sleep(50);
    
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            } while (executor.getCompletedTaskCount() < resultList.size());
    
    
            System.out.println("Results as folloers:");
            for (int i = 0; i < resultList.size(); i++) {
                Future<Integer> result = resultList.get(i);
                Integer number = null;
    
                try {
                    number = result.get();// blocking method
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (ExecutionException e) {
                    e.printStackTrace();
                }
                System.out.printf("task: %d, result %d:\n", i, number);
            }
            executor.shutdown();
        }
    }

在上面  number = result.get(); 语句中，我们 catch了两个异常，一个是InterruptedException，另一个是ExecutionException。因为我们是在main线程内获得任务的执行结果，main线程执行 result.get()会阻塞，如果在阻塞的过程中被(其他线程)中断，则抛出InterruptedException。

**若在任务的执行过程中抛出了异常（比如IllegalArgumentException），那么main线程在这里就会catch到ExecutionException。此时，就可以对抛出异常的任务“进行处理”。此外，线程池中执行该任务的线程，并不会因为 该任务在执行过程中抛出了异常而受到影响，该线程 可以继续 接收并运行 下一次提交给它的任务。**

图中 task1、task2、task4 返回的结果为空，表明它们抛出了IllegalArgumentException异常。

而要想对异常进行处理，可参考：[Java线程池异常处理最佳实践 ][Java]和 [这篇文章][Link 2]。

**参考资料**

《Java 7 Concurrency Cookbook》 chapter 4

原文：http://www.cnblogs.com/hapjin/p/7599189.html

[Link 1]: https://jahidshohel.wordpress.com/2010/11/13/executorservice-for-asynchronous-execution/
[6bad4920fa8b49f79d2b9187809f5555.png]: /images/20221023/e88391e4776f41549af0a5b3169f2c60.png
[ad35e9982d5284967b869c81df160655.png]: /images/20221023/e5b2743fd80847dd9f5ca8d38fa1583f.png
[Java]: http://blog.onlycatch.com/post/Java%E7%BA%BF%E7%A8%8B%E6%B1%A0%E5%BC%82%E5%B8%B8%E5%A4%84%E7%90%86%E6%9C%80%E4%BD%B3%E5%AE%9E%E8%B7%B5
[Link 2]: https://segmentfault.com/a/1190000000669942