diff options
author | somov <somov@yandex-team.ru> | 2022-02-10 16:45:49 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:49 +0300 |
commit | 7489e4682331202b9c7d863c0898eb83d7b12c2b (patch) | |
tree | 9142afc54d335ea52910662635b898e79e192e49 /library/cpp/messagebus/scheduler/scheduler.h | |
parent | a5950576e397b1909261050b8c7da16db58f10b1 (diff) | |
download | ydb-7489e4682331202b9c7d863c0898eb83d7b12c2b.tar.gz |
Restoring authorship annotation for <somov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/scheduler/scheduler.h')
-rw-r--r-- | library/cpp/messagebus/scheduler/scheduler.h | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/library/cpp/messagebus/scheduler/scheduler.h b/library/cpp/messagebus/scheduler/scheduler.h index 996bf30f8c7..afcc0de55d5 100644 --- a/library/cpp/messagebus/scheduler/scheduler.h +++ b/library/cpp/messagebus/scheduler/scheduler.h @@ -1,16 +1,16 @@ -#pragma once - +#pragma once + #include <library/cpp/threading/future/legacy_future.h> #include <util/datetime/base.h> #include <util/generic/object_counter.h> -#include <util/generic/ptr.h> -#include <util/generic/vector.h> -#include <util/system/atomic.h> +#include <util/generic/ptr.h> +#include <util/generic/vector.h> +#include <util/system/atomic.h> #include <util/system/condvar.h> #include <util/system/mutex.h> -#include <util/system/thread.h> - +#include <util/system/thread.h> + namespace NBus { namespace NPrivate { class IScheduleItem { @@ -25,30 +25,30 @@ namespace NBus { private: TInstant ScheduleTime; }; - + using IScheduleItemAutoPtr = TAutoPtr<IScheduleItem>; - + class TScheduler { public: TScheduler(); ~TScheduler(); void Stop(); void Schedule(TAutoPtr<IScheduleItem> i); - + size_t Size() const; - + private: void SchedulerThread(); - + void FillNextItem(); - + private: TVector<IScheduleItemAutoPtr> Items; IScheduleItemAutoPtr NextItem; typedef TMutex TLock; TLock Lock; TCondVar CondVar; - + TObjectCounter<TScheduler> ObjectCounter; bool StopThread; @@ -63,6 +63,6 @@ namespace NBus { inline TInstant IScheduleItem::GetScheduleTime() const noexcept { return ScheduleTime; } - + } -} +} |