|
@@ -8,6 +8,8 @@ import com.tzld.piaoquan.recommend.server.model.Video;
|
|
import com.tzld.piaoquan.recommend.server.service.filter.strategy.BlacklistContainer;
|
|
import com.tzld.piaoquan.recommend.server.service.filter.strategy.BlacklistContainer;
|
|
import com.tzld.piaoquan.recommend.server.service.flowpool.FlowPoolConstants;
|
|
import com.tzld.piaoquan.recommend.server.service.flowpool.FlowPoolConstants;
|
|
import com.tzld.piaoquan.recommend.server.service.recall.strategy.*;
|
|
import com.tzld.piaoquan.recommend.server.service.recall.strategy.*;
|
|
|
|
+import com.tzld.piaoquan.recommend.server.util.CommonCollectionUtils;
|
|
|
|
+import com.tzld.piaoquan.recommend.server.util.JSONUtils;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
@@ -58,6 +60,7 @@ public class RecallService implements ApplicationContextAware {
|
|
|
|
|
|
public RecallResult recall(RecallParam param) {
|
|
public RecallResult recall(RecallParam param) {
|
|
List<RecallStrategy> strategies = getRecallStrategy(param);
|
|
List<RecallStrategy> strategies = getRecallStrategy(param);
|
|
|
|
+ log.info("strategies {}", JSONUtils.toJson(CommonCollectionUtils.toList(strategies, o -> o.getClass().getSimpleName())));
|
|
CountDownLatch cdl = new CountDownLatch(strategies.size());
|
|
CountDownLatch cdl = new CountDownLatch(strategies.size());
|
|
List<Future<RecallResult.RecallData>> recallResultFutures = new ArrayList<>();
|
|
List<Future<RecallResult.RecallData>> recallResultFutures = new ArrayList<>();
|
|
for (final RecallStrategy strategy : strategies) {
|
|
for (final RecallStrategy strategy : strategies) {
|