|
@@ -174,14 +174,8 @@ public class RankStrategyXGBAutoUpdateModel688 extends RankStrategyXGBBasic {
|
|
|
long time3 = System.currentTimeMillis();
|
|
|
// 分桶
|
|
|
this.readBucketFile();
|
|
|
- CountDownLatch cdl4 = new CountDownLatch(adRankItems.size() + 1);
|
|
|
- ThreadPoolFactory.feature().submit(() -> {
|
|
|
- try {
|
|
|
- userFeatureMap = this.featureBucket(userFeatureMap);
|
|
|
- } finally {
|
|
|
- cdl4.countDown();
|
|
|
- }
|
|
|
- });
|
|
|
+ userFeatureMap = this.featureBucket(userFeatureMap);
|
|
|
+ CountDownLatch cdl4 = new CountDownLatch(adRankItems.size());
|
|
|
for (AdRankItem adRankItem : adRankItems) {
|
|
|
ThreadPoolFactory.feature().submit(() -> {
|
|
|
try {
|