Browse Source

ADD: 监控打印时长

sunxy 1 year ago
parent
commit
03cd5e5cdd

+ 2 - 2
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/implement/TopRecommendPipeline.java

@@ -61,7 +61,7 @@ public class TopRecommendPipeline {
                              final User userInfo, Boolean logPrint) {
         // Step 1: Attention extraction
         Stopwatch stopwatch = Stopwatch.createStarted();
-        stopwatch.start();
+        stopwatch.reset().start();
         List<RankItem> rankItems = feedByRec(requestData, requestIndex, userInfo, logPrint);
         if (rankItems == null || rankItems.isEmpty()) {
             return new ArrayList<>();
@@ -118,7 +118,7 @@ public class TopRecommendPipeline {
         Stopwatch stopwatch = Stopwatch.createStarted();
 
         // Step 2: create top queue
-        stopwatch.start();
+        stopwatch.reset().start();
         StrategyQueue topQueue = MergeUtils.createTopQueue(MERGE_CONF, "top-queue");
         if (logPrint) {
             log.info("traceId = {}, cost = {}, topQueue = {}", requestData.getRequestId(),

+ 0 - 1
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/VideoRecommendService.java

@@ -65,7 +65,6 @@ public class VideoRecommendService {
         List<Video> topRecommendVideoList = new ArrayList<>();
         List<Video> flowPoolRecommendVideoList = new ArrayList<>();
         try {
-            stopwatch.start();
             topRecommendVideoList = topRecommendPipeline.feeds(request, 0, user, newLogPrint);
             if (newLogPrint) {
                 log.info("traceId = {}, cost = {}, topRecommendVideoList [{}]", request.getRequestId(),