aboutsummaryrefslogtreecommitdiffstats
path: root/util/thread/pool.cpp
diff options
context:
space:
mode:
authorivanzhukov <ivanzhukov@yandex-team.ru>2022-02-10 16:49:41 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:41 +0300
commitca3252a147a429eac4ba8221857493c58dcd09b5 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /util/thread/pool.cpp
parent0892d79ab411592ad25175c4bdadbcb09b466cf5 (diff)
downloadydb-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.cpp50
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"));