Browse Source

Add: BaseRecaller DEFAULT_QUEUE_LOAD_TIMEOUT

sunxy 1 year ago
parent
commit
ea39fc55b8

+ 2 - 2
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/framework/recaller/BaseRecaller.java

@@ -27,8 +27,8 @@ import java.util.stream.Collectors;
 public class BaseRecaller<Video> {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(BaseRecaller.class);
-    private static final long DEFAULT_QUEUE_LOAD_TIMEOUT = 1000; // ms
-    private static final long DEFAULT_PARALLEL_FILTER_TIMEOUT = 1000; // ms
+    private static final long DEFAULT_QUEUE_LOAD_TIMEOUT = 1500; // ms
+    private static final long DEFAULT_PARALLEL_FILTER_TIMEOUT = 1500; // ms
 
     private static final String FILTER_CONF = "filter_config.conf"; // ms
     private static final ExecutorService filterExecutorService = new ThreadPoolExecutor(128, 128,