aboutsummaryrefslogtreecommitdiffstats
path: root/util/thread
diff options
context:
space:
mode:
authorleo <leo@yandex-team.ru>2022-02-10 16:46:40 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:40 +0300
commit980edcd3304699edf9d4e4d6a656e585028e2a72 (patch)
tree139f47f3911484ae9af0eb347b1a88bd6c4bb35f /util/thread
parentb036a557f285146e5e35d4213e29a094ab907bcf (diff)
downloadydb-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.cpp10
-rw-r--r--util/thread/pool.h6
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: