diff options
author | mihaild <mihaild@yandex-team.ru> | 2022-02-10 16:46:59 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:46:59 +0300 |
commit | 246417ad6168d3f7ab4a0cf1c79ba4259f7c45ae (patch) | |
tree | 2a65611ade91c8ae2f55647107c1a11ea743abd5 /library/cpp/threading/task_scheduler/task_scheduler.cpp | |
parent | 5598c5e7bc7619bd51d87fea7b880b7788ad0b47 (diff) | |
download | ydb-246417ad6168d3f7ab4a0cf1c79ba4259f7c45ae.tar.gz |
Restoring authorship annotation for <mihaild@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/threading/task_scheduler/task_scheduler.cpp')
-rw-r--r-- | library/cpp/threading/task_scheduler/task_scheduler.cpp | 4 |
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 174dde4bf7..fdc160cf05 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))); } } |