diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-09-18 15:27:03 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-09-18 15:27:03 +0200 |
commit | 560c144bc72db8a3335742f6c659d1d312b122a5 (patch) | |
tree | e6fee21547c90077c1158d565bc9dc298fbc22a6 /container-core | |
parent | 1af05b8eaa94e766c3cb19be0a8b98d8f3a2f0fc (diff) |
Add getter for number of queued tasks
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()) { |