如何解决当我使用时间限制器断路器 + 线程池隔板 + 时间限制器时,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 举报,一经查实,本站将立刻删除。