Add getter for number of queued tasks

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()) {