Stack thread

src/util/BatchExecutor.cpp

@@ -19,6 +19,8 @@
 namespace stellar
 {
 
+const size_t WORKER_STACK_BYTES = 1 << 23; // 8 MiB
+
 namespace
 {
 struct CpuPinning
@@ -160,7 +162,7 @@ BatchExecutor::ensureWorkers(size_t count)
     {
         size_t index = mWorkers.size();
         uint64_t batchId = mBatchId;
-        mWorkers.emplace_back(
+        mWorkers.emplace_back(WORKER_STACK_BYTES,
             [this, index, batchId]() { workerLoop(index, batchId); });
         pinWorker(index);
     }

src/util/BatchExecutor.h

@@ -7,6 +7,7 @@
 #include "lib/util/finally.h"
 #include "util/GlobalChecks.h"
 #include "util/NonCopyable.h"
+#include "util/StackThread.h"
 
 #include <atomic>
 #include <condition_variable>
@@ -15,7 +16,6 @@
 #include <exception>
 #include <functional>
 #include <mutex>
-#include <thread>
 #include <type_traits>
 #include <vector>
 
@@ -77,7 +77,7 @@ class BatchExecutor : private NonMovableOrCopyable
     // with std::condition_variable.
     std::mutex mMutex;
     std::condition_variable mCondition;
-    std::vector<std::thread> mWorkers;
+    std::vector<StackThread> mWorkers;
     // All allowed logical CPUs in pinning-preference order.
     std::vector<unsigned> mPinCpuOrder;
     // Number of distinct physical cores found in the allowed logical CPUs.