微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

当我使用时间限制器断路器 + 线程池隔板 + 时间限制器时,JVM 线程用完了

如何解决当我使用时间限制器断路器 + 线程池隔板 + 时间限制器时,JVM 线程用完了

Resilience4j 版本:1.7

Java 版本:8

我是resilience4j 的新手(尽管我对Hystrix 有一定的经验)并且正在尝试学习如何使用它来优化负载下的性能。目前,我编写的代码使用了:断路器、线程池隔板和 TimeLimiter。我观察到,当我使用时间限制器装饰供应商时,在中等负载(每秒大约 90 个请求)下,JVM 会耗尽线程并抛出以下异常。

! java.lang.OutOfMemoryError: unable to create native thread: possibly out of memory or process/resource limits reached

这有效地杀死了服务并导致每个请求失败,直到服务重新启动。当我删除时间限制器时,这个问题就会消失。这是我的代码

final CircuitBreaker circuitBreaker = getCircuitBreaker();
final CheckedFunction0<? extends HttpResponse> supplierWithCircuitBreaker = Decorators
                .ofCheckedsupplier(supplier).withCircuitBreaker(circuitBreaker).decorate();
final TimeLimiter timeLimiter = getTimeLimiter();
scheduledexecutorservice scheduler = Executors.newSingleThreadScheduledExecutor();


final CompletableFuture<? extends HttpResponse> async = Decorators.ofsupplier(() -> {
            try {
                return supplierWithCircuitBreaker.apply();
            } catch (Throwable e) {
                return handleException(e);
            }
        }).withThreadPoolBulkhead(threadPoolBulkhead).withTimeLimiter(timeLimiter,scheduler).get().toCompletableFuture();

async.thenAccept(result -> {
            LOGGER.info(String.format("Returning value: %s",result.getHttpStatus()));
            response.resume(Response.status(result.getHttpStatus()).entity(result).build());
        }).exceptionally(e -> {
            final StandardResponse errorResponse = handleException(e);
            response.resume(Response.status(errorResponse.getHttpStatus()).entity(errorResponse).build());

            // without this the compiler complains
            return null;
        });

谁能告诉我我在这里做错了什么?

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。