有偿问答
面经分享
技术探讨
资料领取
登录
线上接口经常超时,我用线程池+FutureTask解决了,YYDS
社长
1年前
⋅ 545 阅读
之前红包权益领取查询的接口超时了,因为有用户订购的权益有点多 ### 解决方案 ### 用线程池+ 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(),有异常会从这里拿出来 >来源 | https://blog.csdn.net/qq\_44384533/article/details/112324224
阅读全部
全部评论:
0
条
我有话说:
@
发送
-- 目录 --
关注官方公众号:
Java问答社
接收最新有赏问答推送!
最新发布
1.
SpringBoot 接口数据加解密技巧,so easy!
2.
一个依赖搞定 Spring Boot 反爬虫,防止接口盗刷!
3.
Java8 Stream 极大简化了代码,它是如何实现的?
4.
马上大四了,秋招还是春招好?先找工作还是找实习?
5.
万字详解 Linux 常用指令(值得收藏)
6.
4年工作经验,多线程间的5种通信方式都说不出来,你敢信?
最新评论
部署文档没有了,您能提供下吗
部署文档没有了,能提供下吗
我测你的🐎
源码从哪里获取请问
想学
那篇石墨文档 没有权限查看哇