Limit the number of task s in flight to 2x number of threads in the pool.

2 files changed, 5 insertions, 6 deletions

diff --git a/searchcore/src/vespa/searchcore/proton/server/executor_thread_service.h b/searchcore/src/vespa/searchcore/proton/server/executor_thread_service.h
index 47e41fcd1db..c938288c714 100644
--- a/searchcore/src/vespa/searchcore/proton/server/executor_thread_service.h
+++ b/searchcore/src/vespa/searchcore/proton/server/executor_thread_service.h
@@ -33,6 +33,7 @@ public:
         return *this;
     }
     virtual bool isCurrentThread() const override;
+    size_t getNumThreads() const override { return _executor.getNumThreads(); }
 };
 
 } // namespace proton
diff --git a/searchcore/src/vespa/searchcore/proton/test/thread_service_observer.h b/searchcore/src/vespa/searchcore/proton/test/thread_service_observer.h
index a2f0724d396..905ec5ef07b 100644
--- a/searchcore/src/vespa/searchcore/proton/test/thread_service_observer.h
+++ b/searchcore/src/vespa/searchcore/proton/test/thread_service_observer.h
@@ -3,8 +3,7 @@
 
 #include <vespa/searchcorespi/index/i_thread_service.h>
 
-namespace proton {
-namespace test {
+namespace proton::test {
 
 class ThreadServiceObserver : public searchcorespi::index::IThreadService
 {
@@ -38,9 +37,8 @@ public:
     virtual bool isCurrentThread() const override {
         return _service.isCurrentThread();
     }
-};
-
-} // namespace test
-} // namespace proton
+    size_t getNumThreads() const override { return _service.getNumThreads(); }
 
+};
 
+}