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

互联网架构师

共 789字,需浏览 2分钟

 ·

2022-03-09 22:14

上一篇:大规模业务技术架构设计与战术(架构师必看)


作者: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;@Testpublic void test(String[] args) {
//任务列表List> taskList=new ArrayList>();for(int i=0;i<100;i++){//创建100个任务放入【任务列表】FutureTask futureTask=new FutureTask(new Callable() {@Overridepublic 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();//打印: 100System.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(),有异常会从这里拿出来
感谢您的阅读,也欢迎您发表关于这篇文章的任何建议,关注我,技术不迷茫!小编到你上高速。 
    · END ·
最后,关注公众号互联网架构师,在后台回复:2T,可以获取我整理的 Java 系列面试题和答案,非常齐全


正文结束


推荐阅读 ↓↓↓

1.救救大龄码农!45岁程序员在国务院网站求助总理!央媒网评来了...

2.如何才能成为优秀的架构师?

3.从零开始搭建创业公司后台技术栈

4.程序员一般可以从什么平台接私活?

5.37岁程序员被裁,120天没找到工作,无奈去小公司,结果懵了...

6.IntelliJ IDEA 2019.3 首个最新访问版本发布,新特性抢先看

7.这封“领导痛批95后下属”的邮件,句句扎心!

8.15张图看懂瞎忙和高效的区别!


浏览 6
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报