《Dubbo 实现原理与源码解析 —— 精品合集》 《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》 《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》 《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》 《Java 面试题 + Java 学习指南》

摘要: 原创出处 blog.csdn.net/qq_44384533/article/details/112324224 「zhongh Jim」欢迎转载,保留摘要,谢谢!


🙂🙂🙂关注**微信公众号:【芋道源码】**有福利:

  1. RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
  2. RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
  3. 您对于源码的疑问每条留言将得到认真回复。甚至不知道如何读源码也可以请教噢
  4. 新的源码解析文章实时收到通知。每周更新一篇左右
  5. 认真的源码交流微信群。

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

解决方案

用线程池+ 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<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>() {
@Override
public Integer call() throws Exception {
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<?> 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(),有异常会从这里拿出来

文章目录
  1. 1. 解决方案
  2. 2. 线程池 + FutureTask执行多任务计算
  3. 3. 子线程出的异常抛不出的情况