async concurrent llvm compilation

2 files changed, 13 insertions, 0 deletions

diff --git a/vespalib/src/vespa/vespalib/util/threadstackexecutorbase.cpp b/vespalib/src/vespa/vespalib/util/threadstackexecutorbase.cpp
index 969b5e6f61e..e933477bfb9 100644
--- a/vespalib/src/vespa/vespalib/util/threadstackexecutorbase.cpp
+++ b/vespalib/src/vespa/vespalib/util/threadstackexecutorbase.cpp
@@ -177,6 +177,13 @@ ThreadStackExecutorBase::internalSetTaskLimit(uint32_t taskLimit)
     }
 }
 
+size_t
+ThreadStackExecutorBase::num_idle_workers() const
+{
+    LockGuard lock(_monitor);
+    return _workers.size();
+}
+
 ThreadStackExecutorBase::Stats
 ThreadStackExecutorBase::getStats()
 {
diff --git a/vespalib/src/vespa/vespalib/util/threadstackexecutorbase.h b/vespalib/src/vespa/vespalib/util/threadstackexecutorbase.h
index 21a6e9cabe0..8718b04d2d3 100644
--- a/vespalib/src/vespa/vespalib/util/threadstackexecutorbase.h
+++ b/vespalib/src/vespa/vespalib/util/threadstackexecutorbase.h
@@ -198,6 +198,12 @@ protected:
 public:
     ThreadStackExecutorBase(const ThreadStackExecutorBase &) = delete;
     ThreadStackExecutorBase & operator = (const ThreadStackExecutorBase &) = delete;
+
+    /**
+     * Returns the number of idle workers. This is mostly useful for testing.
+     **/
+    size_t num_idle_workers() const;
+
     /**
      * Observe and reset stats for this object.
      *