aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/poor_man_openmp/thread_helper.h
diff options
context:
space:
mode:
authoreeight <eeight@yandex-team.ru>2022-02-10 16:46:19 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:19 +0300
commitbd085aee9b4f7a0bee302ce687964ffb7098f986 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/threading/poor_man_openmp/thread_helper.h
parent475c0a46f28166e83fd263badc7546377cddcabe (diff)
downloadydb-bd085aee9b4f7a0bee302ce687964ffb7098f986.tar.gz
Restoring authorship annotation for <eeight@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/threading/poor_man_openmp/thread_helper.h')
-rw-r--r--library/cpp/threading/poor_man_openmp/thread_helper.h10
1 files changed, 5 insertions, 5 deletions
diff --git a/library/cpp/threading/poor_man_openmp/thread_helper.h b/library/cpp/threading/poor_man_openmp/thread_helper.h
index d1744f217d..0ecee0590b 100644
--- a/library/cpp/threading/poor_man_openmp/thread_helper.h
+++ b/library/cpp/threading/poor_man_openmp/thread_helper.h
@@ -1,6 +1,6 @@
#pragma once
-#include <util/thread/pool.h>
+#include <util/thread/pool.h>
#include <util/generic/utility.h>
#include <util/generic/yexception.h>
#include <util/system/info.h>
@@ -17,7 +17,7 @@ public:
TMtpQueueHelper() {
SetThreadCount(NSystemInfo::CachedNumberOfCpus());
}
- IThreadPool* Get() {
+ IThreadPool* Get() {
return q.Get();
}
size_t GetThreadCount() {
@@ -25,14 +25,14 @@ public:
}
void SetThreadCount(size_t threads) {
ThreadCount = threads;
- q = CreateThreadPool(ThreadCount);
+ q = CreateThreadPool(ThreadCount);
}
static TMtpQueueHelper& Instance();
private:
size_t ThreadCount;
- TAutoPtr<IThreadPool> q;
+ TAutoPtr<IThreadPool> q;
};
namespace NYmp {
@@ -49,7 +49,7 @@ namespace NYmp {
chunkSize = Max<size_t>(chunkSize, 1);
size_t threadCount = TMtpQueueHelper::Instance().GetThreadCount();
- IThreadPool* queue = TMtpQueueHelper::Instance().Get();
+ IThreadPool* queue = TMtpQueueHelper::Instance().Get();
TCondVar cv;
TMutex mutex;
TAtomic counter = threadCount;