线上接口经常超时，我用线程池FutureTask解决了，YYDS

　　作者：zhongh Jim
　　来源：blog.csdn.net/qq_44384533/article/details/112324224
　　之前红包权益领取查询的接口超时了，因为有用户订购的权益有点多
　　# 解决方案：
　　用线程池+ FutureTask将1个查询拆分成多个小查询，选择FutureTask是因为它具有仅执行1次run()方法的特性(即使有多次调用也只执行1次)，避免了重复查询的可能。而且多任务异步执行也能提高接口响应速度。
　　本文主要讲的是线程池搭配FutureTask异步执行的例子
　　# 线程池+FutureTask执行多任务计算
　　public class Test { //线程池最好作为全局变量, 若作为局部变量记得用完后shutdown() ThreadFactory namedThreadFactory = new ThreadFactoryBuilder(）.setNameFormat(＂thread-start-runner-%d＂).build(); ExecutorService taskExe= new ThreadPoolExecutor(10,20,800L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue(100),namedThreadFactory);    int count=0; @Test public void test(String[] args) {      //任务列表 List> taskList=new ArrayList>(); for(int i=0;i<100;i++){ //创建100个任务放入【任务列表】 FutureTask futureTask=new FutureTask(new Callable() { @Override public Integer call() throws Exception { return 1; } }); //执行的结果装回原来的FutureTask中,后续直接遍历集合taskList来获取结果即可 taskList.add(futureTask); taskExe.submit(futureTask); } //获取结果 try{ for(FutureTask 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 callable)的入参。
　　FutureTask执行的结果会放入它的私有变量outcome中，其他线程直接调用futureTask.get()去读取该变量即可
　　# 子线程出得异常抛不出的情况
　　submit(Runnable task)提交任务的方式 ，是存在＂隐患＂的：
　　FutureTask内部的run()代码块会把异常给吞进去，通过setException(Throwable t)把异常赋给了对象outcome，我们在调用FutureTask.get()获取结果的时候返回的就是这个对象
　　如果你的代码没有调用FutureTask.get()，它不会把异常吐出来，有可能子线程就莫名的停止了。  public Future<?> submit(Runnable task) { if (task == null) throw new NullPointerException(); //创建一个异步执行的任务FutureTask, 【隐患】也在它的run()代码块里 RunnableFuture ftask = newTaskFor(task, null); execute(ftask); return ftask; }
　　子线程创建之后会执行的是FutureTask内部的run()代码块，run()内部会有try-catch来截获抛出的异常，将其赋值给对象outcome
　　上面的例子没有这个问题，因为调用了FutureTask.get()，有异常会从这里拿出来