aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/task_scheduler/task_scheduler.cpp
diff options
context:
space:
mode:
authormihaild <mihaild@yandex-team.ru>2022-02-10 16:46:59 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:59 +0300
commit55fa8c7df8dba9a6fda8a807e529a9d04bd88580 (patch)
treeb83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/threading/task_scheduler/task_scheduler.cpp
parent246417ad6168d3f7ab4a0cf1c79ba4259f7c45ae (diff)
downloadydb-55fa8c7df8dba9a6fda8a807e529a9d04bd88580.tar.gz
Restoring authorship annotation for <mihaild@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/threading/task_scheduler/task_scheduler.cpp')
-rw-r--r--library/cpp/threading/task_scheduler/task_scheduler.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/library/cpp/threading/task_scheduler/task_scheduler.cpp b/library/cpp/threading/task_scheduler/task_scheduler.cpp
index fdc160cf05..174dde4bf7 100644
--- a/library/cpp/threading/task_scheduler/task_scheduler.cpp
+++ b/library/cpp/threading/task_scheduler/task_scheduler.cpp
@@ -102,7 +102,7 @@ bool TTaskScheduler::Add(ITaskRef task, TInstant expire) {
with_lock (Lock_) {
if (!IsStopped_ && Workers_.size() > 0 && GetTaskCount() + 1 <= MaxTaskCount_) {
ITaskRef newTask = new TTaskWrapper(task, TaskCounter_);
- Queue_.insert(std::make_pair(expire, TTaskHolder(newTask)));
+ Queue_.insert(std::make_pair(expire, TTaskHolder(newTask)));
if (!Queue_.begin()->second.WaitingWorker) {
CondVar_.Signal();
@@ -216,7 +216,7 @@ void TTaskScheduler::WorkerFunc(TWorkerThread* thread) {
if (!!toDo) {
if (repeat < TInstant::Max()) {
- Queue_.insert(std::make_pair(repeat, TTaskHolder(toDo)));
+ Queue_.insert(std::make_pair(repeat, TTaskHolder(toDo)));
}
}