intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 26 insertions, 0 deletions

diff --git a/library/cpp/threading/future/subscription/wait_ut_common.cpp b/library/cpp/threading/future/subscription/wait_ut_common.cpp
new file mode 100644
index 00000000000..9f961e73036
--- /dev/null
+++ b/library/cpp/threading/future/subscription/wait_ut_common.cpp
@@ -0,0 +1,26 @@
+#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();
+}
+
+}