From c7bb2bf515a0d9c0b6ecd849dc5b83b3b7783022 Mon Sep 17 00:00:00 2001 From: akballal Date: Sat, 11 Mar 2023 00:06:54 +0530 Subject: [PATCH] updated code with lambda to simplify it --- .../support/adpter/DynamicThreadPoolAdapterChoose.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/DynamicThreadPoolAdapterChoose.java b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/DynamicThreadPoolAdapterChoose.java index 39a4ba73..c3169502 100644 --- a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/DynamicThreadPoolAdapterChoose.java +++ b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/DynamicThreadPoolAdapterChoose.java @@ -76,9 +76,7 @@ public class DynamicThreadPoolAdapterChoose { */ public static void replace(Object executor, Executor dynamicThreadPoolExecutor) { Optional dynamicThreadPoolAdapterOptional = DYNAMIC_THREAD_POOL_ADAPTERS.stream().filter(each -> each.match(executor)).findFirst(); - if (dynamicThreadPoolAdapterOptional.isPresent()) { - dynamicThreadPoolAdapterOptional.get().replace(executor, dynamicThreadPoolExecutor); - } + dynamicThreadPoolAdapterOptional.ifPresent(dynamicThreadPoolAdapter -> dynamicThreadPoolAdapter.replace(executor, dynamicThreadPoolExecutor)); } /**