Function main

examples/problem.cpp:125–166

}

int main()
{
  exec::static_thread_pool pool(3);
  auto                     sched = pool.get_scheduler();

  // check_if_starts_inline_and_completes_on_pool(ex::schedule(sched), receiver_t{});
  // check_if_starts_inline_and_completes_on_pool(ex::continues_on(ex::just(), sched), receiver_t{});
  // check_if_starts_inline_and_completes_on_pool(ex::let_value(ex::continues_on(ex::just(), sched), []() { return ex::just(); }), receiver_t{});

  // fails
  // check_if_starts_inline_and_completes_on_pool(ex::starts_on(sched, ex::just()), receiver_t{});

#if 0
  print(
    ex::get_completion_domain<ex::set_value_t>(
      ex::get_env(
        ex::starts_on(sched, ex::just())
      ),
      ex::get_env(receiver_t{})
    )
  );

  std::cout << "main: " << std::this_thread::get_id() << "\n";
  auto snd = ex::starts_on(sched, ex::just())
           | ex::bulk(ex::par_unseq, 2, [](int i) {
    std::cout << "   " << i << ": " << std::this_thread::get_id() << "\n";
  });
  ex::sync_wait(snd);
#else

  [[maybe_unused]]
  bool called{false};
  // launch some work on the thread pool
  ex::sender auto snd =
    ex::starts_on(sched, ex::just())
    //  ex::just() | ex::continues_on(sched) | ex::let_value([]() { return ex::just(); })
    | ex::continues_on(ex::inline_scheduler{});
  ex::sync_wait(std::move(snd));
#endif

  return 0;
}