aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorsabdenovch <sabdenovch@yandex-team.com>2025-06-05 23:42:50 +0300
committersabdenovch <sabdenovch@yandex-team.com>2025-06-06 00:00:10 +0300
commitf27c79a69f6c2be73b36d87010e160d72f297f61 (patch)
treee1180e2dbaa597133ba65361db228ea8acc96950
parent3bb209565d8dffadb79879126206ff4282621a5a (diff)
downloadydb-f27c79a69f6c2be73b36d87010e160d72f297f61.tar.gz
Initialize Fair share thread pool threads correctly
* Changelog entry Type: fix Component: misc-server Fixed bad initialization of threads within fair-share thread pool. commit_hash:1db38c436c8ed4de3b5b86b7dab7e5bd8e1a3100
-rw-r--r--yt/yt/core/concurrency/two_level_fair_share_thread_pool.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/yt/yt/core/concurrency/two_level_fair_share_thread_pool.cpp b/yt/yt/core/concurrency/two_level_fair_share_thread_pool.cpp
index 4ca3f55a555..5661ba78120 100644
--- a/yt/yt/core/concurrency/two_level_fair_share_thread_pool.cpp
+++ b/yt/yt/core/concurrency/two_level_fair_share_thread_pool.cpp
@@ -1272,7 +1272,8 @@ public:
: TSchedulerThread(
std::move(callbackEventCount),
threadGroupName,
- threadName)
+ threadName,
+ {.ThreadInitializer = [this] () { Initialize(); }})
, Queue_(std::move(queue))
, Index_(index)
{ }
@@ -1281,7 +1282,7 @@ protected:
const TTwoLevelFairShareQueuePtr Queue_;
const int Index_;
- void OnStart() override
+ void Initialize()
{
ThreadCookie() = TTaggedPtr(Queue_.Get(), static_cast<ui16>(Index_)).Pack();
}