diff options
author | Nikita Petrenko <npetrenko97@gmail.com> | 2022-02-10 16:50:57 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:57 +0300 |
commit | fd3f62e99d2990dd93788742aaf6a9bd5cb4d5a3 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/threading/future/wait/wait.cpp | |
parent | aa72317474c8df5627f69271ae16f4237e5d3612 (diff) | |
download | ydb-fd3f62e99d2990dd93788742aaf6a9bd5cb4d5a3.tar.gz |
Restoring authorship annotation for Nikita Petrenko <npetrenko97@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/threading/future/wait/wait.cpp')
-rw-r--r-- | library/cpp/threading/future/wait/wait.cpp | 38 |
1 files changed, 19 insertions, 19 deletions
diff --git a/library/cpp/threading/future/wait/wait.cpp b/library/cpp/threading/future/wait/wait.cpp index 8ff1997a2b..a173833a7f 100644 --- a/library/cpp/threading/future/wait/wait.cpp +++ b/library/cpp/threading/future/wait/wait.cpp @@ -1,40 +1,40 @@ #include "wait.h" -#include "wait_group.h" -#include "wait_policy.h" - +#include "wait_group.h" +#include "wait_policy.h" + namespace NThreading { namespace { - template <class WaitPolicy> + template <class WaitPolicy> TFuture<void> WaitGeneric(const TFuture<void>& f1) { - return f1; - } + return f1; + } - template <class WaitPolicy> + template <class WaitPolicy> TFuture<void> WaitGeneric(const TFuture<void>& f1, const TFuture<void>& f2) { - TWaitGroup<WaitPolicy> wg; + TWaitGroup<WaitPolicy> wg; - wg.Add(f1).Add(f2); + wg.Add(f1).Add(f2); - return std::move(wg).Finish(); - } + return std::move(wg).Finish(); + } template <class WaitPolicy> TFuture<void> WaitGeneric(TArrayRef<const TFuture<void>> futures) { - if (futures.empty()) { - return MakeFuture(); + if (futures.empty()) { + return MakeFuture(); } - if (futures.size() == 1) { + if (futures.size() == 1) { return futures.front(); } - TWaitGroup<WaitPolicy> wg; - for (const auto& fut : futures) { - wg.Add(fut); + TWaitGroup<WaitPolicy> wg; + for (const auto& fut : futures) { + wg.Add(fut); } - return std::move(wg).Finish(); - } + return std::move(wg).Finish(); + } } //////////////////////////////////////////////////////////////////////////////// |