summaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/future/wait/wait.cpp
diff options
context:
space:
mode:
authorvskipin <[email protected]>2022-02-10 16:46:00 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:46:00 +0300
commit4d8b546b89b5afc08cf3667e176271c7ba935f33 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/threading/future/wait/wait.cpp
parent4e4b78bd7b67e2533da4dbb9696374a6d6068e32 (diff)
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/threading/future/wait/wait.cpp')
-rw-r--r--library/cpp/threading/future/wait/wait.cpp32
1 files changed, 16 insertions, 16 deletions
diff --git a/library/cpp/threading/future/wait/wait.cpp b/library/cpp/threading/future/wait/wait.cpp
index 5d040985f28..a173833a7f9 100644
--- a/library/cpp/threading/future/wait/wait.cpp
+++ b/library/cpp/threading/future/wait/wait.cpp
@@ -1,5 +1,5 @@
#include "wait.h"
-
+
#include "wait_group.h"
#include "wait_policy.h"
@@ -9,16 +9,16 @@ namespace NThreading {
TFuture<void> WaitGeneric(const TFuture<void>& f1) {
return f1;
}
-
+
template <class WaitPolicy>
TFuture<void> WaitGeneric(const TFuture<void>& f1, const TFuture<void>& f2) {
TWaitGroup<WaitPolicy> wg;
-
+
wg.Add(f1).Add(f2);
-
+
return std::move(wg).Finish();
}
-
+
template <class WaitPolicy>
TFuture<void> WaitGeneric(TArrayRef<const TFuture<void>> futures) {
if (futures.empty()) {
@@ -32,13 +32,13 @@ namespace NThreading {
for (const auto& fut : futures) {
wg.Add(fut);
}
-
+
return std::move(wg).Finish();
}
}
-
+
////////////////////////////////////////////////////////////////////////////////
-
+
TFuture<void> WaitAll(const TFuture<void>& f1) {
return WaitGeneric<TWaitPolicy::TAll>(f1);
}
@@ -57,26 +57,26 @@ namespace NThreading {
TFuture<void> WaitExceptionOrAll(const TFuture<void>& f1) {
return WaitGeneric<TWaitPolicy::TExceptionOrAll>(f1);
}
-
+
TFuture<void> WaitExceptionOrAll(const TFuture<void>& f1, const TFuture<void>& f2) {
return WaitGeneric<TWaitPolicy::TExceptionOrAll>(f1, f2);
}
-
+
TFuture<void> WaitExceptionOrAll(TArrayRef<const TFuture<void>> futures) {
return WaitGeneric<TWaitPolicy::TExceptionOrAll>(futures);
- }
+ }
////////////////////////////////////////////////////////////////////////////////
-
+
TFuture<void> WaitAny(const TFuture<void>& f1) {
return WaitGeneric<TWaitPolicy::TAny>(f1);
}
-
+
TFuture<void> WaitAny(const TFuture<void>& f1, const TFuture<void>& f2) {
return WaitGeneric<TWaitPolicy::TAny>(f1, f2);
}
-
+
TFuture<void> WaitAny(TArrayRef<const TFuture<void>> futures) {
return WaitGeneric<TWaitPolicy::TAny>(futures);
- }
-}
+ }
+}