recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score/ScorerPipeline.java

@@ -67,6 +67,7 @@ public class ScorerPipeline {
                         if (future.isDone() && !future.isCancelled() && future.get() != null) {
                             scoredItems.addAll(future.get());
                         } else {
+                            future.cancel(true);
                             LOGGER.error("score task is cancelled, scorename [{}] fail items [{}]",
                                     new Object[]{scorerName, scoreRankerItems.size()});
                         }
@@ -142,6 +143,7 @@ public class ScorerPipeline {
                         if (future.isDone() && !future.isCancelled() && future.get() != null) {
                             scoredItems.addAll(future.get());
                         } else {
+                            future.cancel(true);
                             LOGGER.error("score task is cancelled, scorename [{}] fail items [{}]",
                                     new Object[]{scorerName, scoreRankerItems.size()});
                         }
@@ -226,6 +228,7 @@ public class ScorerPipeline {
                         if (future.isDone() && !future.isCancelled() && future.get() != null) {
                             scoredItems.addAll(future.get());
                         } else {
+                            future.cancel(true);
                             LOGGER.error("score task is cancelled, scorename [{}] fail items [{}]",
                                     new Object[]{scorerName, scoreRankerItems.size()});
                         }