diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2018-10-24 07:48:52 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2018-10-24 07:48:52 +0200 |
commit | 9f88cfb2ac36ea523919aa115d7038cee12c19ad (patch) | |
tree | 76e682f5d8d3341ec32819e710eed66ff9fba949 /vespaclient-core/src | |
parent | 4b97ebddad6965f9dfa299b8932a4396decfc721 (diff) |
Properly close tasks.
Diffstat (limited to 'vespaclient-core/src')
-rwxr-xr-x | vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java | 6 |
1 files changed, 6 insertions, 0 deletions
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; |