aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/task_scheduler
diff options
context:
space:
mode:
authorVlad Yaroslavlev <vladon@vladon.com>2022-02-10 16:46:25 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:25 +0300
commit344ea37b4a345701ab0e67de2266a1c1bd7baf2d (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/threading/task_scheduler
parent706b83ed7de5a473436620367af31fc0ceecde07 (diff)
downloadydb-344ea37b4a345701ab0e67de2266a1c1bd7baf2d.tar.gz
Restoring authorship annotation for Vlad Yaroslavlev <vladon@vladon.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/threading/task_scheduler')
-rw-r--r--library/cpp/threading/task_scheduler/task_scheduler.cpp6
-rw-r--r--library/cpp/threading/task_scheduler/task_scheduler.h10
2 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/threading/task_scheduler/task_scheduler.cpp b/library/cpp/threading/task_scheduler/task_scheduler.cpp
index 4e2239c2d7..174dde4bf7 100644
--- a/library/cpp/threading/task_scheduler/task_scheduler.cpp
+++ b/library/cpp/threading/task_scheduler/task_scheduler.cpp
@@ -18,8 +18,8 @@ public:
{
}
- TString DebugState = "?";
- TString DebugId = "";
+ TString DebugState = "?";
+ TString DebugId = "";
private:
void* ThreadProc() noexcept override {
Scheduler_.WorkerFunc(this);
@@ -150,7 +150,7 @@ bool TTaskScheduler::Add(IRepeatedTaskRef task, TDuration period) {
const bool debugOutput = false;
-void TTaskScheduler::ChangeDebugState(TWorkerThread* thread, const TString& state) {
+void TTaskScheduler::ChangeDebugState(TWorkerThread* thread, const TString& state) {
if (!debugOutput) {
Y_UNUSED(thread);
Y_UNUSED(state);
diff --git a/library/cpp/threading/task_scheduler/task_scheduler.h b/library/cpp/threading/task_scheduler/task_scheduler.h
index e2381c2b38..df4da941a8 100644
--- a/library/cpp/threading/task_scheduler/task_scheduler.h
+++ b/library/cpp/threading/task_scheduler/task_scheduler.h
@@ -40,10 +40,10 @@ private:
TWorkerThread* WaitingWorker = nullptr;
};
- using TQueueType = TMultiMap<TInstant, TTaskHolder>;
- using TQueueIterator = TQueueType::iterator;
+ using TQueueType = TMultiMap<TInstant, TTaskHolder>;
+ using TQueueIterator = TQueueType::iterator;
private:
- void ChangeDebugState(TWorkerThread* thread, const TString& state);
+ void ChangeDebugState(TWorkerThread* thread, const TString& state);
void ChooseFromQueue(TQueueIterator& toWait);
bool Wait(TWorkerThread* thread, TQueueIterator& toWait);
@@ -52,12 +52,12 @@ private:
bool IsStopped_ = false;
TAtomic TaskCounter_ = 0;
- TQueueType Queue_;
+ TQueueType Queue_;
TCondVar CondVar_;
TMutex Lock_;
- TVector<TAutoPtr<TWorkerThread>> Workers_;
+ TVector<TAutoPtr<TWorkerThread>> Workers_;
const size_t MaxTaskCount_;
};