From 706b83ed7de5a473436620367af31fc0ceecde07 Mon Sep 17 00:00:00 2001
From: Vlad Yaroslavlev <vladon@vladon.com>
Date: Thu, 10 Feb 2022 16:46:23 +0300
Subject: Restoring authorship annotation for Vlad Yaroslavlev
<vladon@vladon.com>. Commit 1 of 2.
---
library/cpp/threading/task_scheduler/task_scheduler.cpp | 6 +++---
library/cpp/threading/task_scheduler/task_scheduler.h | 10 +++++-----
2 files changed, 8 insertions(+), 8 deletions(-)
(limited to 'library/cpp/threading/task_scheduler')
diff --git a/library/cpp/threading/task_scheduler/task_scheduler.cpp b/library/cpp/threading/task_scheduler/task_scheduler.cpp
index 174dde4bf7..4e2239c2d7 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 df4da941a8..e2381c2b38 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_;
};
--
cgit v1.2.3