intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 73 insertions, 0 deletions

diff --git a/library/cpp/threading/future/legacy_future_ut.cpp b/library/cpp/threading/future/legacy_future_ut.cpp
new file mode 100644
index 0000000000..ff63db1725
--- /dev/null
+++ b/library/cpp/threading/future/legacy_future_ut.cpp
@@ -0,0 +1,73 @@
+#include "legacy_future.h"
+
+#include <library/cpp/testing/unittest/registar.h>
+
+namespace NThreading {
+    Y_UNIT_TEST_SUITE(TLegacyFutureTest) {
+        int intf() {
+            return 17;
+        }
+
+        Y_UNIT_TEST(TestIntFunction) {
+            TLegacyFuture<int> f((&intf));
+            UNIT_ASSERT_VALUES_EQUAL(17, f.Get());
+        }
+
+        static int r;
+
+        void voidf() {
+            r = 18;
+        }
+
+        Y_UNIT_TEST(TestVoidFunction) {
+            r = 0;
+            TLegacyFuture<> f((&voidf));
+            f.Get();
+            UNIT_ASSERT_VALUES_EQUAL(18, r);
+        }
+
+        struct TSampleClass {
+            int mValue;
+
+            TSampleClass(int value)
+                : mValue(value)
+            {
+            }
+
+            int Calc() {
+                return mValue + 1;
+            }
+        };
+
+        Y_UNIT_TEST(TestMethod) {
+            TLegacyFuture<int> f11(std::bind(&TSampleClass::Calc, TSampleClass(3)));
+            UNIT_ASSERT_VALUES_EQUAL(4, f11.Get());
+
+            TLegacyFuture<int> f12(std::bind(&TSampleClass::Calc, TSampleClass(3)), SystemThreadFactory());
+            UNIT_ASSERT_VALUES_EQUAL(4, f12.Get());
+
+            TSampleClass c(5);
+
+            TLegacyFuture<int> f21(std::bind(&TSampleClass::Calc, std::ref(c)));
+            UNIT_ASSERT_VALUES_EQUAL(6, f21.Get());
+
+            TLegacyFuture<int> f22(std::bind(&TSampleClass::Calc, std::ref(c)), SystemThreadFactory());
+            UNIT_ASSERT_VALUES_EQUAL(6, f22.Get());
+        }
+
+        struct TSomeThreadPool: public IThreadFactory {};
+
+        Y_UNIT_TEST(TestFunction) {
+            std::function<int()> f((&intf));
+
+            UNIT_ASSERT_VALUES_EQUAL(17, TLegacyFuture<int>(f).Get());
+            UNIT_ASSERT_VALUES_EQUAL(17, TLegacyFuture<int>(f, SystemThreadFactory()).Get());
+
+            if (false) {
+                TSomeThreadPool* q = nullptr;
+                TLegacyFuture<int>(f, q); // just check compiles, do not start
+            }
+        }
+    }
+
+}