Merge pull request #16825 from ydb-platform/merge-libs-250407-0050

1 files changed, 8 insertions, 2 deletions

diff --git a/library/cpp/threading/local_executor/tbb_local_executor.h b/library/cpp/threading/local_executor/tbb_local_executor.h
index 8d790db18c..f67c07349d 100644
--- a/library/cpp/threading/local_executor/tbb_local_executor.h
+++ b/library/cpp/threading/local_executor/tbb_local_executor.h
@@ -9,6 +9,9 @@
 #include <contrib/libs/tbb/include/tbb/task_arena.h>
 #include <contrib/libs/tbb/include/tbb/task_group.h>
 
+#include <atomic>
+
+
 namespace NPar {
     template <bool RespectTls = false>
     class TTbbLocalExecutor final: public ILocalExecutor  {
@@ -16,10 +19,11 @@ namespace NPar {
         TTbbLocalExecutor(int nThreads)
             : ILocalExecutor()
             , TbbArena(nThreads)
-            , NumberOfTbbThreads(nThreads) {}
+            , NumberOfTbbThreads(nThreads)
+            , RegisteredThreadCounter(0)
+        {}
         ~TTbbLocalExecutor() noexcept override {}
 
-        // 0-based ILocalExecutor worker thread identification
         virtual int GetWorkerThreadId() const noexcept override;
         virtual int GetThreadCount() const noexcept override;
 
@@ -45,5 +49,7 @@ namespace NPar {
         mutable tbb::task_arena TbbArena;
         tbb::task_group Group;
         int NumberOfTbbThreads;
+
+        mutable std::atomic_int RegisteredThreadCounter;
     };
 }