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

编程问答 2022-05-17

问题描述

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 (将#修改为@）

asynchronousjavajavamultithreadingmultithreadingresilience4j