diff options
author | tender-bum <tender-bum@yandex-team.ru> | 2022-02-10 16:50:01 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:01 +0300 |
commit | 4aef354b224559d2b031487a10d4f5cc6e82e95a (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util/thread/pool.cpp | |
parent | c78b06a63de7beec995c1007bc5332bdf3d75b69 (diff) | |
download | ydb-4aef354b224559d2b031487a10d4f5cc6e82e95a.tar.gz |
Restoring authorship annotation for <tender-bum@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/thread/pool.cpp')
-rw-r--r-- | util/thread/pool.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/util/thread/pool.cpp b/util/thread/pool.cpp index 6f99c21e59..05fad02e9b 100644 --- a/util/thread/pool.cpp +++ b/util/thread/pool.cpp @@ -68,7 +68,7 @@ TThreadFactoryHolder::TThreadFactoryHolder() noexcept class TThreadPool::TImpl: public TIntrusiveListItem<TImpl>, public IThreadFactory::IThreadAble { using TTsr = IThreadPool::TTsr; using TJobQueue = TFastQueue<IObjectInQueue*>; - using TThreadRef = THolder<IThreadFactory::IThread>; + using TThreadRef = THolder<IThreadFactory::IThread>; public: inline TImpl(TThreadPool* parent, size_t thrnum, size_t maxqueue, const TParams& params) @@ -415,7 +415,7 @@ public: private: TImpl* Impl_; - THolder<IThreadFactory::IThread> Thread_; + THolder<IThreadFactory::IThread> Thread_; }; inline TImpl(TAdaptiveThreadPool* parent, const TParams& params) @@ -647,8 +647,8 @@ namespace { THolder<IObjectInQueue> Owned; public: - TOwnedObjectInQueue(THolder<IObjectInQueue> owned) - : Owned(std::move(owned)) + TOwnedObjectInQueue(THolder<IObjectInQueue> owned) + : Owned(std::move(owned)) { } @@ -663,12 +663,12 @@ void IThreadPool::SafeAdd(IObjectInQueue* obj) { Y_ENSURE_EX(Add(obj), TThreadPoolException() << TStringBuf("can not add object to queue")); } -void IThreadPool::SafeAddAndOwn(THolder<IObjectInQueue> obj) { +void IThreadPool::SafeAddAndOwn(THolder<IObjectInQueue> obj) { Y_ENSURE_EX(AddAndOwn(std::move(obj)), TThreadPoolException() << TStringBuf("can not add to queue and own")); } -bool IThreadPool::AddAndOwn(THolder<IObjectInQueue> obj) { - auto owner = MakeHolder<TOwnedObjectInQueue>(std::move(obj)); +bool IThreadPool::AddAndOwn(THolder<IObjectInQueue> obj) { + auto owner = MakeHolder<TOwnedObjectInQueue>(std::move(obj)); bool added = Add(owner.Get()); if (added) { Y_UNUSED(owner.Release()); |