diff options
author | alex-sh <alex-sh@yandex-team.ru> | 2022-02-10 16:50:03 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:03 +0300 |
commit | 3196904c9f5bf7aff7374eeadcb0671589581f61 (patch) | |
tree | d13114a178799aeb203a4b3b43dd7fb0c4f6975f /util/thread/pool.cpp | |
parent | d154d11651ea533127249184148c3f023e2c6d0a (diff) | |
download | ydb-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.cpp | 14 |
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; +} |