文档章节

CompletableFuture get方法一直阻塞或抛出TimeoutException

x
 xiaolyuh
发布于 2018/12/16 00:13
字数 986
阅读 36
收藏 2

问题描述

最近刚刚上线的服务突然抛出大量的TimeoutException,查询后发现是使用了CompletableFuture,并且在执行future.get(5, TimeUnit.SECONDS);时抛出了TimeoutException异常,导致接口响应很慢进而影响了其他系统的调用。

问题分析

首先我们知道CompletableFuture的get()方法值会阻塞主线程,直到子线程执行任务完成返回结果才会取消阻塞。如果子线程一直不返回接口那么主线程就会一直阻塞,所以我们一般不建议直接使用CompletableFuture的get()方法,而是使用future.get(5, TimeUnit.SECONDS);方法指定超时时间。

但是当我们的线程池拒绝策略使用的是DiscardPolicy或者DiscardOldestPolicy,并且线程池饱和了的时候,我们将会直接丢弃任务,不会抛出任何异常。这个时候再来调用get方法是主线程就会一直等待子线程返回结果,直到超时抛出TimeoutException。

我们来看下面一段代码:

@RunWith(SpringRunner.class)
@SpringBootTest
public class CompletableFutureTest {
    Logger logger = LoggerFactory.getLogger(CompletableFutureTest.class);
    ThreadPoolTaskExecutor taskExecutor = null;

    @Before
    public void before() {
        taskExecutor = new ThreadPoolTaskExecutor();
        // 核心线程数
        taskExecutor.setCorePoolSize(1);
        // 最大线程数
        taskExecutor.setMaxPoolSize(1);
        // 队列最大长度
        taskExecutor.setQueueCapacity(2);
        // 线程池维护线程所允许的空闲时间(单位秒)
        taskExecutor.setKeepAliveSeconds(60);
        /*
         * 线程池对拒绝任务(无限程可用)的处理策略
         * ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
         * ThreadPoolExecutor.DiscardPolicy:也是丢弃任务,但是不抛出异常。
         * ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)
         * ThreadPoolExecutor.CallerRunsPolicy:由调用线程处理该任务,如果执行器已关闭,则丢弃.
         */
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
        taskExecutor.initialize();
    }

    @Test
    public void testGet() throws Exception {
        for (int i = 1; i < 100; i++) {
            new Thread(() -> {
                // 第一步非常耗时,会沾满线程池
                taskExecutor.execute(() -> {
                    sleep(5000);
                });

                // 第二步不耗时的操作,但是get的时候会报TimeoutException
                CompletableFuture<Object> future1 = CompletableFuture.supplyAsync(() -> 1, taskExecutor);
                CompletableFuture<Object> future2 = CompletableFuture.supplyAsync(() -> 2, taskExecutor);
                try {
                    System.out.println(Thread.currentThread().getName() + "::value1" + future1.get(1, TimeUnit.SECONDS));
                    System.out.println(Thread.currentThread().getName() + "::value2" + future2.get(1, TimeUnit.SECONDS));
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();
        }


        sleep(30000);
    }

    /**
     * @param millis 毫秒
     * @Title: sleep
     * @Description: 线程等待时间
     * @author yuhao.wang
     */
    private void sleep(long millis) {
        try {
            Thread.sleep(millis);
        } catch (InterruptedException e) {
            logger.info("获取分布式锁休眠被中断:", e);
        }
    }
}

我们可以看到第一步的异步线程时一个非常耗时的线程,第二步的两个CompletableFuture是一个非常快的异步操作。按照道理来说future1.get(1, TimeUnit.SECONDS)这一步是不因该报TimeOut的。但是我们发现我们线程池拒绝策略使用的是DiscardPolicy,当线程池满了会直接丢弃任务,而不会终止主线程。这个时候执行get方法的时候,主线线程一直会等待直到超时为止。所以接口响应速度一下就慢了下来。

解决方案

  1. 在使用CompletableFuture时线程池拒绝策略最好使用AbortPolicy。直接中断主线程,达到快速失败的效果。
  2. 耗时的异步线程和CompletableFuture的线程做线程池隔离,让耗时操作不影响主线程的执行

总结

  1. 在使用CompletableFuture的时候线程池拒绝策略最好使用AbortPolicy,如果线程池满了直接抛出异常中断主线程,达到快速失败的效果
  2. 耗时的异步线程和CompletableFuture的线程做线程池隔离,让耗时操作不影响主线程的执行
  3. 不建议直接使用CompletableFuture的get()方法,而是使用future.get(5, TimeUnit.SECONDS);方法指定超时时间

源码

https://github.com/wyh-spring-ecosystem-student/spring-boot-student/tree/releases

spring-boot-student-completable-future 工程

为监控而生的多级缓存框架 layering-cache这是我开源的一个多级缓存框架的实现,如果有兴趣可以看一下。

© 著作权归作者所有

共有 人打赏支持
上一篇: 系统重构笔记
下一篇: Rabbit MQ 延迟队列
x
粉丝 23
博文 24
码字总数 35161
作品 0
成都
私信 提问
Java8新的异步编程方式 CompletableFuture(一)

一. Future JDK 5引入了Future模式。Future接口是Java多线程Future模式的实现,在java.util.concurrent包中,可以来进行异步计算。 Future模式是多线程设计常用的一种设计模式。Future模式可...

Tony沈哲
2017/10/21
0
0
聊聊lettuce的sentinel连接

序 本文主要研究一下lettuce的sentinel连接 RedisClient.connectSentinel lettuce-core-5.0.4.RELEASE-sources.jar!/io/lettuce/core/RedisClient.java connectSentinel方法,会遍历sentine......

go4it
2018/09/13
0
0
“用 CompletableFuture 处理异步超时” 阅读总结

译文:http://www.importnew.com/16149.html 原文:http://www.javacodegeeks.com/2014/12/asynchronous-timeouts-with-completablefuture.html 总结 为什么要引入 方法会阻塞线程,一直阻塞......

编走编想
2015/10/11
492
0
深度学习Java Future (一)

作者: 一字马胡 转载标志 【2017-12-07】 更新日志 日期 更新内容 备注 2017-12-07 学习Future的总结 关于Future的深入学习内容 Future 上面这段文字已经说明了Future的本质,一个Future代表...

一字马胡
2017/12/07
0
0
Java8 - 使用CompletableFuture(一)

Future 的使用 自Java 5开始添加了,用来描述一个异步计算的结果。获取一个结果时方法较少,要么通过轮询,确认完成后调用获取值,要么调用设置一个超时时间。但是方法会阻塞调用线程,这种阻...

秋风醉了
2018/09/30
0
0

没有更多内容

加载失败,请刷新页面

加载更多

uml类图

平时阅读一些远吗分析类文章或是设计应用架构时没少与UML类图打交道。实际上,UML类图中最常用到的元素五分钟就能掌握,下面赶紧来一起认识一下它吧: 一、类的属性的表示方式 在UML类图中,...

asdf08442a
7分钟前
0
0
Linux下执行脚本报错提示invalid option 3: set: -

1、在环境下执行sh报错invalid option 3: set: - 2、于是换成chmod 777 install.sh改执行权限,并且默认使用#!/bin/bash bash: ./install.sh: /bin/bash^M: bad interpreter: No such file ......

noob_chr
7分钟前
0
0
phpstrom2018激活与汉化

phpstrom2018激活与汉化 方法一. 直接用浏览器打开 http://idea.lanyus.com/ (推荐) 点击页面中的“获得注册码”,然后在注册时切换至Activation Code选项,输入获得的注册码一长串字符串,...

万建宁
9分钟前
0
0
Kali Linux NetHunter教程Kali NetHunter支持的设备和ROMs

Kali Linux NetHunter教程Kali NetHunter支持的设备和ROMs NetHunter是一个基于Kali Linux为Nexus设备构建的Android渗透测试平台,其中包括一些特殊和独特的功能。NetHunter支持无线802.11注...

大学霸
18分钟前
1
0
端口可用性探测

在服务器上打开了一个端口,我们需要测试是否开启成功是否可用,可以在本机使用 traceroute (linux)工具 traceroute 是几乎所有 Linux 发行版本预装的网络测试工具,用于跟踪 Internet 协议(...

applepaihs
18分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部