diff options
author | ivanzhukov <ivanzhukov@yandex-team.ru> | 2022-02-10 16:49:41 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:41 +0300 |
commit | ca3252a147a429eac4ba8221857493c58dcd09b5 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util/thread/pool.cpp | |
parent | 0892d79ab411592ad25175c4bdadbcb09b466cf5 (diff) | |
download | ydb-ca3252a147a429eac4ba8221857493c58dcd09b5.tar.gz |
Restoring authorship annotation for <ivanzhukov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/thread/pool.cpp')
-rw-r--r-- | util/thread/pool.cpp | 50 |
1 files changed, 25 insertions, 25 deletions
diff --git a/util/thread/pool.cpp b/util/thread/pool.cpp index f3c4ecc7bc..05fad02e9b 100644 --- a/util/thread/pool.cpp +++ b/util/thread/pool.cpp @@ -143,10 +143,10 @@ public: return ThreadCountExpected; } - inline size_t GetThreadCountReal() const noexcept { - return ThreadCountReal; - } - + inline size_t GetThreadCountReal() const noexcept { + return ThreadCountReal; + } + inline void AtforkAction() noexcept Y_NO_SANITIZE("thread") { Forked = true; } @@ -326,29 +326,29 @@ size_t TThreadPool::Size() const noexcept { } size_t TThreadPool::GetThreadCountExpected() const noexcept { - if (!Impl_.Get()) { - return 0; - } - - return Impl_->GetThreadCountExpected(); -} - + if (!Impl_.Get()) { + return 0; + } + + return Impl_->GetThreadCountExpected(); +} + size_t TThreadPool::GetThreadCountReal() const noexcept { - if (!Impl_.Get()) { - return 0; - } - - return Impl_->GetThreadCountReal(); -} - + if (!Impl_.Get()) { + return 0; + } + + return Impl_->GetThreadCountReal(); +} + size_t TThreadPool::GetMaxQueueSize() const noexcept { - if (!Impl_.Get()) { - return 0; - } - - return Impl_->GetMaxQueueSize(); -} - + if (!Impl_.Get()) { + return 0; + } + + return Impl_->GetMaxQueueSize(); +} + bool TThreadPool::Add(IObjectInQueue* obj) { Y_ENSURE_EX(Impl_.Get(), TThreadPoolException() << TStringBuf("mtp queue not started")); |