diff options
| author | Brian Gesiak <modocache@gmail.com> | 2019-03-26 17:46:06 +0000 |
|---|---|---|
| committer | Brian Gesiak <modocache@gmail.com> | 2019-03-26 17:46:06 +0000 |
| commit | 57839425aa4802986acbb17392ca697ee76aa633 (patch) | |
| tree | 9e173f9d545ee0dd2a54e5a7fca96a216130cc39 /libcxx/test/std/experimental/task/task.basic/task_of_void.pass.cpp | |
| parent | 52221d56bcf3d087bb88d44b56c682fd27f59a13 (diff) | |
| download | bcm5719-llvm-57839425aa4802986acbb17392ca697ee76aa633.tar.gz bcm5719-llvm-57839425aa4802986acbb17392ca697ee76aa633.zip | |
[coroutines] Add std::experimental::task<T> type
Summary:
Adds the coroutine `std::experimental::task<T>` type described in proposal P1056R0.
See https://wg21.link/P1056R0.
This implementation allows customization of the allocator used to allocate the
coroutine frame by passing std::allocator_arg as the first argument, followed by
the allocator to use.
This supports co_awaiting the same task multiple times. The second and
subsequent times it returns a reference to the already-computed value.
This diff also adds some implementations of other utilities that have potential for
standardization as helpers within the test/... area:
- `sync_wait(awaitable)` - See P1171R0
- `manual_reset_event`
Move the definition of the __aligned_allocation_size helper function
from <experimental/memory_resource> to <experimental/__memory>
so it can be more widely used without pulling in memory_resource.
Outstanding work:
- Use C++14 keywords directly rather than macro versions
eg. use `noexcept` instead of `_NOEXCEPT`).
- Add support for overaligned coroutine frames.
This may need wording in the Coroutines TS to support passing the extra `std::align_val_t`.
- Eliminate use of `if constexpr` if we want it to compile under C++14.
Patch by @lewissbaker (Lewis Baker).
llvm-svn: 357010
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.cpp | 96 |
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; +} |

