Class thread

test/exec/asio/test_completion_token.cpp:466–507

  }

  class thread
  {
    asio_impl::io_context                                                ctx_;
    asio_impl::executor_work_guard<asio_impl::io_context::executor_type> g_;
    std::thread                                                          t_;
   public:
    thread()
      : g_(ctx_.get_executor())
      , t_(
          [&]() noexcept
          {
            STDEXEC_TRY
            {
              ctx_.run();
            }
            STDEXEC_CATCH_ALL
            {
              FAIL("Exception thrown in background thread");
            }
          })
    {}

    ~thread() noexcept
    {
      g_.reset();
      if (t_.joinable())
      {
        t_.join();
      }
    }

    void join() noexcept
    {
      g_.reset();
      t_.join();
    }

    asio_impl::io_context& context() noexcept
    {
      return ctx_;
    }
  };

  template <typename CompletionHandler>
  struct ping_pong