@@ -347,8 +347,7 @@ public class RankStrategy4RegionMergeModelV562 extends RankStrategy4RegionMergeM
// 超时后取消
for (Future<Integer> future : futures) {
try {
- if (future.isDone() && !future.isCancelled()) {
- } else {
+ if (!future.isDone()) {
future.cancel(true);
}
} catch (Exception e) {
@@ -306,8 +306,7 @@ public class RankStrategy4RegionMergeModelV564 extends RankStrategy4RegionMergeM
@@ -332,8 +332,7 @@ public class RankStrategy4RegionMergeModelV566 extends RankStrategy4RegionMergeM
@@ -332,8 +332,7 @@ public class RankStrategy4RegionMergeModelV567 extends RankStrategy4RegionMergeM
@@ -306,8 +306,7 @@ public class RankStrategy4RegionMergeModelV568 extends RankStrategy4RegionMergeM