From 9f88cfb2ac36ea523919aa115d7038cee12c19ad Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Wed, 24 Oct 2018 07:48:52 +0200 Subject: Properly close tasks. --- .../src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java index ada4cfb1725..8661a4e4db1 100755 --- a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java +++ b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java @@ -123,6 +123,9 @@ public final class VespaFeedHandler extends VespaFeedHandlerBase { public boolean isAborted() { return simpleFeedAccess.isAborted(); } + void close() { + executor.shutdown(); + } } public HttpResponse handle(HttpRequest request, RouteMetricSet.ProgressCallback callback, int numThreads) { @@ -162,6 +165,9 @@ public final class VespaFeedHandler extends VespaFeedHandlerBase { } sender.done(); + if (feedAccess instanceof ThreadedFeedAccess) { + ((ThreadedFeedAccess)feedAccess).close(); + } if (asynchronous) { return response; -- cgit v1.2.3