diff options
| author | onpopov <onpopov@yandex-team.ru> | 2022-02-10 16:50:38 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:38 +0300 |
| commit | 8773f7661194d4c0bdb1e3937b2ff7ae01dd13f8 (patch) | |
| tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util/thread | |
| parent | 84a29dd4980d5b39615e453f289bd1a81213296d (diff) | |
| download | ydb-8773f7661194d4c0bdb1e3937b2ff7ae01dd13f8.tar.gz | |
Restoring authorship annotation for <onpopov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/thread')
| -rw-r--r-- | util/thread/pool.cpp | 4 | ||||
| -rw-r--r-- | util/thread/pool.h | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/util/thread/pool.cpp b/util/thread/pool.cpp index 10b74efb80..05fad02e9b 100644 --- a/util/thread/pool.cpp +++ b/util/thread/pool.cpp @@ -592,7 +592,7 @@ size_t TAdaptiveThreadPool::Size() const noexcept { void TAdaptiveThreadPool::SetMaxIdleTime(TDuration interval) { Y_ENSURE_EX(Impl_.Get(), TThreadPoolException() << TStringBuf("mtp queue not started")); - Impl_->SetMaxIdleTime(interval); + Impl_->SetMaxIdleTime(interval); } TSimpleThreadPool::~TSimpleThreadPool() { @@ -623,7 +623,7 @@ void TSimpleThreadPool::Start(size_t thrnum, size_t maxque) { tmp->Start(thrnum, maxque); if (adaptive) { - adaptive->SetMaxIdleTime(TDuration::Seconds(100)); + adaptive->SetMaxIdleTime(TDuration::Seconds(100)); } Slave_.Swap(tmp); diff --git a/util/thread/pool.h b/util/thread/pool.h index 9f92eec8da..d1ea3a67cb 100644 --- a/util/thread/pool.h +++ b/util/thread/pool.h @@ -10,8 +10,8 @@ #include <util/generic/noncopyable.h> #include <functional> -class TDuration; - +class TDuration; + struct IObjectInQueue { virtual ~IObjectInQueue() = default; |