aboutsummaryrefslogtreecommitdiffstats
path: root/util/system/thread.cpp
diff options
context:
space:
mode:
authorcerevra <cerevra@yandex-team.ru>2022-02-10 16:45:58 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:58 +0300
commitbf41dd01f6c920583e9faae7cd55ed25e547e052 (patch)
treeec7c8c285ffa648a5c5efeff453787a15ab811ac /util/system/thread.cpp
parente2c3e3004f7cd68441cefcfa4aaccd3d8051c846 (diff)
downloadydb-bf41dd01f6c920583e9faae7cd55ed25e547e052.tar.gz
Restoring authorship annotation for <cerevra@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/system/thread.cpp')
-rw-r--r--util/system/thread.cpp30
1 files changed, 15 insertions, 15 deletions
diff --git a/util/system/thread.cpp b/util/system/thread.cpp
index 6236746c2d..d529776f49 100644
--- a/util/system/thread.cpp
+++ b/util/system/thread.cpp
@@ -251,23 +251,23 @@ namespace {
class TThread::TImpl: public TThreadBase {
public:
- inline TImpl(const TParams& params, THolder<TCallableBase> callable = {})
+ inline TImpl(const TParams& params, THolder<TCallableBase> callable = {})
: TThreadBase(params)
- , Callable_(std::move(callable))
+ , Callable_(std::move(callable))
{
}
inline TId Id() const noexcept {
return ThreadIdHashFunction(SystemThreadId());
}
-
- static THolder<TImpl> Create(THolder<TCallableBase> callable) {
- TParams params(TCallableBase::ThreadWorker, callable.Get());
- return MakeHolder<TImpl>(std::move(params), std::move(callable));
- }
-
-private:
- THolder<TCallableBase> Callable_;
+
+ static THolder<TImpl> Create(THolder<TCallableBase> callable) {
+ TParams params(TCallableBase::ThreadWorker, callable.Get());
+ return MakeHolder<TImpl>(std::move(params), std::move(callable));
+ }
+
+private:
+ THolder<TCallableBase> Callable_;
};
TThread::TThread(const TParams& p)
@@ -280,11 +280,11 @@ TThread::TThread(TThreadProc threadProc, void* param)
{
}
-TThread::TThread(TPrivateCtor, THolder<TCallableBase> callable)
- : Impl_(TImpl::Create(std::move(callable)))
-{
-}
-
+TThread::TThread(TPrivateCtor, THolder<TCallableBase> callable)
+ : Impl_(TImpl::Create(std::move(callable)))
+{
+}
+
TThread::~TThread() {
Join();
}