msb-public
/
hippo4j
mirror of https://github.com/longtai-cn/hippo4j
1
0
Code Issues Projects Releases Wiki Activity

use lambda to simplify the code (#1105)

Browse Source
pull/1113/head
邓联龙 3 years ago committed by LiXuemin
parent 6c43c1c8f6
commit 8d011346bc
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File

4
hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/DynamicThreadPoolAdapterChoose.java
Unescape View File

@ -76,9 +76,7 @@ public class DynamicThreadPoolAdapterChoose {
*/ */
public static void replace(Object executor, Executor dynamicThreadPoolExecutor) { public static void replace(Object executor, Executor dynamicThreadPoolExecutor) {
Optional<DynamicThreadPoolAdapter> dynamicThreadPoolAdapterOptional = DYNAMIC_THREAD_POOL_ADAPTERS.stream().filter(each -> each.match(executor)).findFirst(); Optional<DynamicThreadPoolAdapter> dynamicThreadPoolAdapterOptional = DYNAMIC_THREAD_POOL_ADAPTERS.stream().filter(each -> each.match(executor)).findFirst();
if (dynamicThreadPoolAdapterOptional.isPresent()) { dynamicThreadPoolAdapterOptional.ifPresent(dynamicThreadPoolAdapter -> dynamicThreadPoolAdapter.replace(executor, dynamicThreadPoolExecutor));
dynamicThreadPoolAdapterOptional.get().replace(executor, dynamicThreadPoolExecutor);
}
} }
/** /**

Write Preview
Loading…
Cancel
Save