summaryrefslogtreecommitdiffstats
path: root/libcxx/test/std/experimental/task/task.basic/task_of_void.pass.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'libcxx/test/std/experimental/task/task.basic/task_of_void.pass.cpp')
-rw-r--r--libcxx/test/std/experimental/task/task.basic/task_of_void.pass.cpp96
1 files changed, 96 insertions, 0 deletions
diff --git a/libcxx/test/std/experimental/task/task.basic/task_of_void.pass.cpp b/libcxx/test/std/experimental/task/task.basic/task_of_void.pass.cpp
new file mode 100644
index 00000000000..de860b5db6a
--- /dev/null
+++ b/libcxx/test/std/experimental/task/task.basic/task_of_void.pass.cpp
@@ -0,0 +1,96 @@
+// -*- C++ -*-
+//===----------------------------------------------------------------------===//
+//
+// The LLVM Compiler Infrastructure
+//
+// This file is dual licensed under the MIT and the University of Illinois Open
+// Source Licenses. See LICENSE.TXT for details.
+//
+//===----------------------------------------------------------------------===//
+
+// UNSUPPORTED: c++98, c++03, c++11, c++14
+
+#include <experimental/task>
+#include "../manual_reset_event.hpp"
+#include "../sync_wait.hpp"
+
+#include <optional>
+#include <thread>
+
+namespace coro = std::experimental::coroutines_v1;
+
+static bool has_f_executed = false;
+
+static coro::task<void> f()
+{
+ has_f_executed = true;
+ co_return;
+}
+
+static void test_coroutine_executes_lazily()
+{
+ coro::task<void> t = f();
+ assert(!has_f_executed);
+ coro::sync_wait(t);
+ assert(has_f_executed);
+}
+
+static std::optional<int> last_value_passed_to_g;
+
+static coro::task<void> g(int a)
+{
+ last_value_passed_to_g = a;
+ co_return;
+}
+
+void test_coroutine_accepts_arguments()
+{
+ auto t = g(123);
+ assert(!last_value_passed_to_g);
+ coro::sync_wait(t);
+ assert(last_value_passed_to_g);
+ assert(*last_value_passed_to_g == 123);
+}
+
+int shared_value = 0;
+int read_value = 0;
+
+coro::task<void> consume_async(manual_reset_event& event)
+{
+ co_await event;
+ read_value = shared_value;
+}
+
+void produce(manual_reset_event& event)
+{
+ shared_value = 101;
+ event.set();
+}
+
+void test_async_completion()
+{
+ manual_reset_event e;
+ std::thread t1{ [&e]
+ {
+ sync_wait(consume_async(e));
+ }};
+
+ assert(read_value == 0);
+
+ std::thread t2{ [&e] { produce(e); }};
+
+ t1.join();
+
+ assert(read_value == 101);
+
+ t2.join();
+}
+
+int main()
+{
+ test_coroutine_executes_lazily();
+ test_coroutine_accepts_arguments();
+ test_async_completion();
+
+ return 0;
+}
OpenPOWER on IntegriCloud