线程池FutureTask异步执行多任务实现详解

目录

• 题引
• 解决方案
• 一、线程池+FutureTask执行多任务计算
• 二、子线程出的异常抛不出的情况

题引

之前红包权益领取查询的接口超时了，因为有用户订购的权益有点多

解决方案

用线程池+ FutureTask将1个查询拆分成多个小查询

选择FutureTask是因为它具有仅执行1次run()方法的特性(即使有多次调用也只执行1次)，避免了重复查询的可能。而且多任务异步执行也能提高接口响应速度。

若对FutureTask仅执行1次run()有疑问，可看: FutureTask为何仅执行一次run()？

本文主要讲的是线程池搭配FutureTask异步执行的例子

一、线程池+FutureTask执行多任务计算

public class Test {
    //线程池最好作为全局变量, 若作为局部变量记得用完后shutdown()
    ThreadFactory namedThreadFactory =www.devze.com new ThreadFactoryBuilder(）.setNameFormat("thread-start-runner-%d").build();
    ExecutorService taskExe= new ThreadPoolExecutor(10,20,800L, TimeUnit.MILLISECONDS,new LinkedblockingQueue<Runnable>(100),namedThreadFactory);
    
    int count=0;
    @Test
    public void test(String[] args) {
        
        //任务列表
        List<FutureTask<Integer>> taskList=new ArrayList<FutureTask<Integer>>();
        for(int i=0;i<100;i++){
            //创建100个任务放入【任务列表】
            FutureTask<Integer> futureTask=new FutureTask<Integer>(new Callable<Integer>() {
              php  @Override
                public Integer call() throws Exception {
            php        return 1;
                }
            });
            //执行的结果装回原来的FutureTask中,后续直接遍历集合taskList来获取结果即可
            taskList.add(futureTask);
            taskExe.submit(futureTask);
        }
        //获取结果
        try{
            for(FutureTask<Integer> futureTask:taskList){
                count+=futureTask.get();
            }
        } catch (InterruptedException e) {
            logger.error("线程执行被中断",e);
        } catch (ExecutionException e) {
            logger.error("线程执行出现异常",e);
        }
        //关闭线程池
        taskExe.shutdown();
        //打印: 100
        System.out.println(count);
    }
}

Callable接口能让我们拿到线程的执行结果，所以让它作为FutureTask构造函数FutureTask(Callable<V> callable)的入参。

FutureTask执行的结果会放入它的私有变量outcome中，其他线程直接调用futureTask.get()去读取该变量即可

二、子线程出的异常抛不出的情况

submit(Runnable task)提交任务的方式 ，是存在“隐患”的：

FutureTask内部的run()代码块会把异常给吞进去，通过setException(Throwable t)把异常赋给了对象outcome，我们在调用FutureTask.get()获取结果的时候返回的就是这个对象

如果你的代码没有调用FutureTask.get()，它不会把异常吐出来，有可能子线程就莫名的停止了。

public Future<www.devze.com?> submit(Runnable task) {
    if (task == null) throw new NullPointerException();
    //创建一个异步执行的任务FutureTask, 【隐患】也在它的run()代码块里
    RunnableFuture<Void> ftask = newTaskFor(task, null);
    execute(ftask);
    return ftask;
}

子线程创建之后会执行的是FutureTask内部的run()代码块，run()内部会有try-catch来截获抛出的异常，将其赋值给对象outcome

上面的例子没有这个问题，因为调用了FutureTask.get()，有异常会从这里拿出来

关于线程池的参数设置，会在下文 线程池参数自定义设置及详解中说明，在这写就太长了

以上就是线程池FutureTask异步执行多任务实现详解的详细内容，更多关于线程池FutureTask异步执行多任务的资料请关注编编程程客栈(www.devze.com)其它相关文章！