线上接口经常超时,我用线程池+ FutureTask解决了,YYDS
互联网架构师
共 789字,需浏览 2分钟
·
2022-03-09 22:14
作者:zhongh Jim
来源:blog.csdn.net/qq_44384533/article/details/112324224
之前红包权益领取查询的接口超时了,因为有用户订购的权益有点多
解决方案:
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);
}
}
子线程出的异常抛不出的情况
如果你的代码没有调用FutureTask.get(),它不会把异常吐出来,有可能子线程就莫名的停止了。
public Future> submit(Runnable task) {
if (task == null) throw new NullPointerException();
//创建一个异步执行的任务FutureTask, 【隐患】也在它的run()代码块里
RunnableFuture
ftask = newTaskFor(task, null); execute(ftask);
return ftask;
}
正文结束
1.救救大龄码农!45岁程序员在国务院网站求助总理!央媒网评来了...
5.37岁程序员被裁,120天没找到工作,无奈去小公司,结果懵了...
评论