async_scope.cpp

#include "../../relacy/relacy_std.hpp"
#include "../../relacy/relacy_cli.hpp"

#include <stdexec/execution.hpp>
#include <exec/async_scope.hpp>
#include <exec/static_thread_pool.hpp>
#include <exec/single_thread_context.hpp>

#include <optional>
#include <stdexcept>

using rl::nvar;
using rl::nvolatile;
using rl::mutex;

namespace ex = stdexec;
using exec::async_scope;

struct drop_async_scope_future : rl::test_suite<drop_async_scope_future, 1> {
  static size_t const dynamic_thread_count = 1;

  void thread(unsigned) {
    exec::single_thread_context ctx;
    ex::scheduler auto sch = ctx.get_scheduler();

    exec::async_scope scope;
    std::atomic_bool produced{false};
    ex::sender auto begin = ex::schedule(sch);
    {
      ex::sender auto ftr =
        scope.spawn_future(begin | stdexec::then([&]() { produced.store(true); }));
      (void) ftr;
    }
    stdexec::sync_wait(scope.on_empty() | stdexec::then([&]() { RL_ASSERT(produced.load()); }));
  }
};

struct attach_async_scope_future : rl::test_suite<attach_async_scope_future, 1> {
  static size_t const dynamic_thread_count = 1;

  void thread(unsigned) {
    exec::single_thread_context ctx;
    ex::scheduler auto sch = ctx.get_scheduler();

    exec::async_scope scope;
    std::atomic_bool produced{false};
    ex::sender auto begin = ex::schedule(sch);
    ex::sender auto ftr =
      scope.spawn_future(begin | stdexec::then([&]() { produced.store(true); }));
    ex::sender auto ftr_then = std::move(ftr) | stdexec::then([&] { RL_ASSERT(produced.load()); });
    stdexec::sync_wait(stdexec::when_all(scope.on_empty(), std::move(ftr_then)));
  }
};

struct async_scope_future_set_result : rl::test_suite<async_scope_future_set_result, 1> {
  static size_t const dynamic_thread_count = 1;

  void thread(unsigned) {
    struct throwing_copy {
      throwing_copy() = default;

      throwing_copy(const throwing_copy&) {
        throw std::logic_error("");
      }
    };

    exec::single_thread_context ctx;
    ex::scheduler auto sch = ctx.get_scheduler();

    exec::async_scope scope;
    ex::sender auto begin = ex::schedule(sch);
    ex::sender auto ftr = scope.spawn_future(begin | stdexec::then([] { return throwing_copy(); }));
    bool threw = false;
    try {
      stdexec::sync_wait(std::move(ftr));
      RL_ASSERT(false);
    } catch (const std::logic_error&) {
      threw = true;
    }
    RL_ASSERT(threw);
    stdexec::sync_wait(scope.on_empty());
  }
};

template <int test_case>
struct async_scope_request_stop : rl::test_suite<async_scope_request_stop<test_case>, 1> {
  static size_t const dynamic_thread_count = 1;

  void thread(unsigned) {
    exec::single_thread_context ctx;
    ex::scheduler auto sch = ctx.get_scheduler();

    if constexpr (test_case == 0) {
      exec::async_scope scope;
      ex::sender auto begin = ex::schedule(sch);
      ex::sender auto ftr = scope.spawn_future(scope.spawn_future(begin));
      scope.request_stop();
      stdexec::sync_wait(ex::when_all(scope.on_empty(), std::move(ftr)));
    } else {
      exec::async_scope scope;
      ex::sender auto begin = ex::schedule(sch);
      {
        // Drop the future on the floor
        ex::sender auto ftr = scope.spawn_future(scope.spawn_future(begin));
      }
      scope.request_stop();
      stdexec::sync_wait(scope.on_empty());
    }
  }
};

auto main() -> int {
  rl::test_params p;
  p.iteration_count = 100000;
  p.execution_depth_limit = 10000;
  rl::simulate<drop_async_scope_future>(p);
  rl::simulate<attach_async_scope_future>(p);
  rl::simulate<async_scope_future_set_result>(p);
  rl::simulate<async_scope_request_stop<0>>(p);
  rl::simulate<async_scope_request_stop<1>>(p);
  return 0;
}