召回改造

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

@@ -83,7 +83,7 @@ public abstract class AbstractFilterService {
 //                .collect(Collectors.groupingBy(it -> it / chunkSize))
 //                .values();
 
-        int chunkSize = 10;
+        int chunkSize = 100;
         List<List<Long>> chunks = new ArrayList<>();
         int size = videoIds.size();
 
@@ -102,7 +102,7 @@ public abstract class AbstractFilterService {
             futures.add(future);
         }
         try {
-            cdl.await(1000, TimeUnit.MILLISECONDS);
+            cdl.await(800, TimeUnit.MILLISECONDS);
         } catch (InterruptedException e) {
             log.error("filter error", e);
             return null;