From ce369b3e30cd3dc2eb95716f3cc2420cfecf59f8 Mon Sep 17 00:00:00 2001 From: tjq Date: Fri, 9 Sep 2022 00:31:54 +0800 Subject: [PATCH] feat: optimize parseEffectRows --- .../server/persistence/monitor/DatabaseMonitorAspect.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/monitor/DatabaseMonitorAspect.java b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/monitor/DatabaseMonitorAspect.java index 392bae15..71aef266 100644 --- a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/monitor/DatabaseMonitorAspect.java +++ b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/monitor/DatabaseMonitorAspect.java @@ -14,6 +14,7 @@ import tech.powerjob.server.monitor.monitors.ServerMonitor; import javax.annotation.Resource; import java.util.Collection; import java.util.Optional; +import java.util.stream.Stream; /** * 监控切面 @@ -64,6 +65,8 @@ public class DatabaseMonitorAspect { private static Integer parseEffectRows(Object ret) { + // 从性能角度考虑,最高频场景放在最前面判断 + if (ret instanceof Number) { return ((Number) ret).intValue(); } @@ -77,6 +80,9 @@ public class DatabaseMonitorAspect { return ((Slice) ret).getSize(); } + if (ret instanceof Stream) { + return null; + } // TODO: 直接返回对象的方法全部改成 Optional return ret == null ? 0 : 1;