|
@@ -1,7 +1,6 @@
|
|
|
package com.tzld.piaoquan.recommend.server.framework.recaller;
|
|
|
|
|
|
|
|
|
-import com.alibaba.fastjson.JSONObject;
|
|
|
import com.google.common.base.Stopwatch;
|
|
|
import com.google.common.collect.FluentIterable;
|
|
|
import com.google.common.collect.Lists;
|
|
@@ -28,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 = 150; // ms
|
|
|
- private static final long DEFAULT_PARALLEL_FILTER_TIMEOUT = 200; // ms
|
|
|
+ private static final long DEFAULT_QUEUE_LOAD_TIMEOUT = 1000; // ms
|
|
|
+ private static final long DEFAULT_PARALLEL_FILTER_TIMEOUT = 1000; // ms
|
|
|
|
|
|
private static final String FILTER_CONF = "filter_config.conf"; // ms
|
|
|
private static final ExecutorService filterExecutorService = new ThreadPoolExecutor(128, 128,
|