aboutsummaryrefslogtreecommitdiffstats
path: root/util/thread/pool.cpp
diff options
context:
space:
mode:
authoralex-sh <alex-sh@yandex-team.ru>2022-02-10 16:50:03 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:03 +0300
commit3196904c9f5bf7aff7374eeadcb0671589581f61 (patch)
treed13114a178799aeb203a4b3b43dd7fb0c4f6975f /util/thread/pool.cpp
parentd154d11651ea533127249184148c3f023e2c6d0a (diff)
downloadydb-3196904c9f5bf7aff7374eeadcb0671589581f61.tar.gz
Restoring authorship annotation for <alex-sh@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/thread/pool.cpp')
-rw-r--r--util/thread/pool.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/util/thread/pool.cpp b/util/thread/pool.cpp
index 05fad02e9b..6a7ad9c2cc 100644
--- a/util/thread/pool.cpp
+++ b/util/thread/pool.cpp
@@ -759,14 +759,14 @@ namespace {
IThread* IThreadPool::DoCreate() {
return new TPoolThread(this);
}
-
+
THolder<IThreadPool> CreateThreadPool(size_t threadsCount, size_t queueSizeLimit, const TThreadPoolParams& params) {
THolder<IThreadPool> queue;
- if (threadsCount > 1) {
+ if (threadsCount > 1) {
queue.Reset(new TThreadPool(params));
- } else {
+ } else {
queue.Reset(new TFakeThreadPool());
- }
- queue->Start(threadsCount, queueSizeLimit);
- return queue;
-}
+ }
+ queue->Start(threadsCount, queueSizeLimit);
+ return queue;
+}