diff options
| author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-09-21 14:24:56 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-21 14:24:56 +0200 |
| commit | ed9ed2be991da5e0af53d81a6dbf31b78eefdb22 (patch) | |
| tree | c17aa33b0c683650e53f53100bba404cb78b60bb /container-core | |
| parent | 9d905aeb2ec4a04e946585a0553579d34151596a (diff) | |
| parent | 849c980b2470bbba975fd3e4a14f43fabdbf9cc2 (diff) | |
Merge pull request #14451 from vespa-engine/bjorncs/feed-handler-cleanup
Bjorncs/feed handler cleanup
Diffstat (limited to 'container-core')
2 files changed, 3 insertions, 0 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/handler/threadpool/ContainerThreadPool.java b/container-core/src/main/java/com/yahoo/container/handler/threadpool/ContainerThreadPool.java index e2d38427de1..294453aa8ba 100644 --- a/container-core/src/main/java/com/yahoo/container/handler/threadpool/ContainerThreadPool.java +++ b/container-core/src/main/java/com/yahoo/container/handler/threadpool/ContainerThreadPool.java @@ -49,6 +49,7 @@ public class ContainerThreadPool extends AbstractComponent implements AutoClosea } public Executor executor() { return threadpool; } + public int queuedTasks() { return threadpool.queuedTasks(); } @Override public void close() { closeInternal(); } @Override public void deconstruct() { closeInternal(); super.deconstruct(); } diff --git a/container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java b/container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java index 1144d1ebbf6..9a73c98597a 100644 --- a/container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java +++ b/container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java @@ -43,6 +43,8 @@ class ExecutorServiceWrapper extends ForwardingExecutorService { metricReporter.start(); } + int queuedTasks() { return wrapped.getQueue().size(); } + private final void reportMetrics() { try { while (!closed.get()) { |