diff options
author | monster <monster@ydb.tech> | 2022-07-07 14:41:37 +0300 |
---|---|---|
committer | monster <monster@ydb.tech> | 2022-07-07 14:41:37 +0300 |
commit | 06e5c21a835c0e923506c4ff27929f34e00761c2 (patch) | |
tree | 75efcbc6854ef9bd476eb8bf00cc5c900da436a2 /library/cpp/threading/future/subscription/wait_ut_common.cpp | |
parent | 03f024c4412e3aa613bb543cf1660176320ba8f4 (diff) | |
download | ydb-06e5c21a835c0e923506c4ff27929f34e00761c2.tar.gz |
fix ya.make
Diffstat (limited to 'library/cpp/threading/future/subscription/wait_ut_common.cpp')
-rw-r--r-- | library/cpp/threading/future/subscription/wait_ut_common.cpp | 26 |
1 files changed, 0 insertions, 26 deletions
diff --git a/library/cpp/threading/future/subscription/wait_ut_common.cpp b/library/cpp/threading/future/subscription/wait_ut_common.cpp deleted file mode 100644 index 9f961e73036..00000000000 --- a/library/cpp/threading/future/subscription/wait_ut_common.cpp +++ /dev/null @@ -1,26 +0,0 @@ -#include "wait_ut_common.h" - -#include <util/random/shuffle.h> -#include <util/system/event.h> -#include <util/thread/pool.h> - -namespace NThreading::NTest::NPrivate { - -void ExecuteAndWait(TVector<std::function<void()>> jobs, TFuture<void> waiter, size_t threads) { - Y_ENSURE(threads > 0); - Shuffle(jobs.begin(), jobs.end()); - auto pool = CreateThreadPool(threads); - TManualEvent start; - for (auto& j : jobs) { - pool->SafeAddFunc( - [&start, job = std::move(j)]() { - start.WaitI(); - job(); - }); - } - start.Signal(); - waiter.Wait(); - pool->Stop(); -} - -} |