homepage recommend

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/ThreadPoolFactory.java

@@ -12,15 +12,15 @@ import java.util.concurrent.TimeUnit;
  */
 public final class ThreadPoolFactory {
     private final static ExecutorService DEFAULT = new ThreadPoolExecutor(
-            4,
-            16,
+            32,
+            32,
             0L, TimeUnit.SECONDS,
             new LinkedBlockingQueue<>(1000),
-            new ThreadFactoryBuilder().setNameFormat("RecallService-%d").build(),
+            new ThreadFactoryBuilder().setNameFormat("DEFAULT-%d").build(),
             new ThreadPoolExecutor.AbortPolicy());
     public final static ExecutorService RECALL = new ThreadPoolExecutor(
-            4,
-            16,
+            64,
+            64,
             0L, TimeUnit.SECONDS,
             new LinkedBlockingQueue<>(1000),
             new ThreadFactoryBuilder().setNameFormat("RecallService-%d").build(),

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/rank/RankService.java

@@ -35,7 +35,7 @@ public class RankService {
 
         if (param.isSpecialRecommend()) {
             Optional<RecallResult.RecallData> data = param.getRecallResult().getData().stream()
-                    .filter(d -> d.getPushForm().equals(SpecialRecallStrategy.PUSH_FROM))
+                    .filter(d -> d.getPushFrom().equals(SpecialRecallStrategy.PUSH_FROM))
                     .findFirst();
             if (data.isPresent()
                     && data.get() != null) {
@@ -127,14 +127,14 @@ public class RankService {
         }
     }
 
-    private List<Video> extractAndSort(RankParam param, String pushForm) {
+    private List<Video> extractAndSort(RankParam param, String pushFrom) {
         if (param == null
                 || param.getRecallResult() == null
                 || CollectionUtils.isEmpty(param.getRecallResult().getData())) {
             return Collections.emptyList();
         }
         Optional<RecallResult.RecallData> data = param.getRecallResult().getData().stream()
-                .filter(d -> d.getPushForm().equals(pushForm))
+                .filter(d -> d.getPushFrom().equals(pushFrom))
                 .findFirst();
         if (data.isPresent()
                 && data.get() != null

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/recall/RecallResult.java

@@ -20,7 +20,7 @@ public class RecallResult {
     @AllArgsConstructor
     @NoArgsConstructor
     public static class RecallData {
-        private String pushForm;
+        private String pushFrom;
         private List<Video> videos;
     }