correct issue

vladstepanyuk · vladstepanyuk · commit dac212249772 · 2025-10-30T11:54:35.000Z
diff --git a/cloud/storage/core/libs/common/thread_pool.cpp b/cloud/storage/core/libs/common/thread_pool.cpp
@@ -82,13 +82,13 @@ class TThreadPool final
         , SpinCycles(DurationToCyclesSafe(SPIN_TIMEOUT))
         , MemoryTagScope(std::move(memoryTagScope))
         , Workers(numWorkers)
+        , RunningWorkers(NumWorkers)
     {
         size_t i = 1;
         for (auto& worker: Workers) {
             worker.Name = TStringBuilder() << threadName << i++;
             worker.Thread = std::make_unique<TWorkerThread>(*this, worker);
         }
-        AtomicSet(RunningWorkers, NumWorkers);
     }
 
     ~TThreadPool() override

Original file line number	Diff line number	Diff line change
`@@ -82,13 +82,13 @@ class TThreadPool final`
`82`	`82`	`, SpinCycles(DurationToCyclesSafe(SPIN_TIMEOUT))`
`83`	`83`	`, MemoryTagScope(std::move(memoryTagScope))`
`84`	`84`	`, Workers(numWorkers)`
	`85`	`+ , RunningWorkers(NumWorkers)`
`85`	`86`	`{`
`86`	`87`	`size_t i = 1;`
`87`	`88`	`for (auto& worker: Workers) {`
`88`	`89`	`worker.Name = TStringBuilder() << threadName << i++;`
`89`	`90`	`worker.Thread = std::make_unique<TWorkerThread>(*this, worker);`
`90`	`91`	`}`
`91`		`- AtomicSet(RunningWorkers, NumWorkers);`
`92`	`92`	`}`
`93`	`93`
`94`	`94`	`~TThreadPool() override`