diff options
author | leo <leo@yandex-team.ru> | 2022-02-10 16:46:40 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:46:40 +0300 |
commit | 980edcd3304699edf9d4e4d6a656e585028e2a72 (patch) | |
tree | 139f47f3911484ae9af0eb347b1a88bd6c4bb35f /util/thread | |
parent | b036a557f285146e5e35d4213e29a094ab907bcf (diff) | |
download | ydb-980edcd3304699edf9d4e4d6a656e585028e2a72.tar.gz |
Restoring authorship annotation for <leo@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/thread')
-rw-r--r-- | util/thread/pool.cpp | 10 | ||||
-rw-r--r-- | util/thread/pool.h | 6 |
2 files changed, 8 insertions, 8 deletions
diff --git a/util/thread/pool.cpp b/util/thread/pool.cpp index 05fad02e9b..a83b996daa 100644 --- a/util/thread/pool.cpp +++ b/util/thread/pool.cpp @@ -1,7 +1,7 @@ #include <atomic> #include <util/system/defaults.h> - + #if defined(_unix_) #include <pthread.h> #endif @@ -21,7 +21,7 @@ #include <util/system/atomic.h> #include <util/system/condvar.h> #include <util/system/thread.h> - + #include <util/datetime/base.h> #include "factory.h" @@ -122,7 +122,7 @@ public: } Queue.Push(obj); - } + } QueuePushCond.Signal(); @@ -357,8 +357,8 @@ bool TThreadPool::Add(IObjectInQueue* obj) { } return Impl_->Add(obj); -} - +} + void TThreadPool::Start(size_t thrnum, size_t maxque) { Impl_.Reset(new TImpl(this, thrnum, maxque, Params)); } diff --git a/util/thread/pool.h b/util/thread/pool.h index d1ea3a67cb..e6c5a34625 100644 --- a/util/thread/pool.h +++ b/util/thread/pool.h @@ -1,5 +1,5 @@ #pragma once - + #include "fwd.h" #include "factory.h" @@ -311,8 +311,8 @@ public: private: class TImpl; THolder<TImpl> Impl_; -}; - +}; + /** Behave like TThreadPool or TAdaptiveThreadPool, choosen by thrnum parameter of Start() */ class TSimpleThreadPool: public TThreadPoolBase { public: |