diff options
author | sabdenovch <sabdenovch@yandex-team.com> | 2025-06-05 23:42:50 +0300 |
---|---|---|
committer | sabdenovch <sabdenovch@yandex-team.com> | 2025-06-06 00:00:10 +0300 |
commit | f27c79a69f6c2be73b36d87010e160d72f297f61 (patch) | |
tree | e1180e2dbaa597133ba65361db228ea8acc96950 | |
parent | 3bb209565d8dffadb79879126206ff4282621a5a (diff) | |
download | ydb-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.cpp | 5 |
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(); } |