kcenon::container::async::detail::async_awaitable< T > Struct Template Reference

Awaitable that runs work in a separate thread. More...

#include <async_container.h>

Collaboration diagram for kcenon::container::async::detail::async_awaitable< T >:

Public Member Functions
	async_awaitable (std::function< T()> work)
	async_awaitable (async_awaitable &&) noexcept=default
async_awaitable &	operator= (async_awaitable &&) noexcept=default
	async_awaitable (const async_awaitable &)=delete
async_awaitable &	operator= (const async_awaitable &)=delete
bool	await_ready () const noexcept
void	await_suspend (std::coroutine_handle<> handle)
T	await_resume ()

Public Attributes
std::shared_ptr< async_state< T > >	state_

Detailed Description

template<typename T>
struct kcenon::container::async::detail::async_awaitable< T >

Awaitable that runs work in a separate thread.

Uses shared_ptr to manage state, ensuring the worker thread can safely access state even if the awaitable is moved.

Definition at line 90 of file async_container.h.

Constructor & Destructor Documentation

async_awaitable() [1/3]

template<typename T >

kcenon::container::async::detail::async_awaitable< T >::async_awaitable ( std::function< T()> work )

inlineexplicit

Definition at line 94 of file async_container.h.

                : state_(std::make_shared<async_state<T>>(std::move(work))) {}

async_awaitable() [2/3]

template<typename T >

kcenon::container::async::detail::async_awaitable< T >::async_awaitable ( async_awaitable< T > && )

defaultnoexcept

async_awaitable() [3/3]

template<typename T >

kcenon::container::async::detail::async_awaitable< T >::async_awaitable ( const async_awaitable< T > & )

delete

Member Function Documentation

await_ready()

template<typename T >

bool kcenon::container::async::detail::async_awaitable< T >::await_ready ( ) const

inlinenodiscardnoexcept

Definition at line 103 of file async_container.h.

            {
                return false;
            }

await_resume()

template<typename T >

T kcenon::container::async::detail::async_awaitable< T >::await_resume ( )

inline

Definition at line 125 of file async_container.h.

            {
                // Acquire barrier synchronizes with the release store above,
                // ensuring all writes in the worker thread are visible here
                while (!state_->ready_.load(std::memory_order_acquire)) {
                    // Spin until ready - in practice, handle.resume()
                    // ensures we only get here after ready_ is set
                }
                if (state_->exception_) {
                    std::rethrow_exception(state_->exception_);
                }
                return std::move(*state_->result_);
            }

References kcenon::container::async::detail::async_awaitable< T >::state_.

await_suspend()

template<typename T >

void kcenon::container::async::detail::async_awaitable< T >::await_suspend ( std::coroutine_handle<> handle )

inline

Definition at line 108 of file async_container.h.

            {
                // Copy shared_ptr for thread to ensure state lifetime
                auto state = state_;
                std::thread([state, handle]() mutable {
                    try {
                        state->result_.emplace(state->work_());
                    } catch (...) {
                        state->exception_ = std::current_exception();
                    }
                    // Release barrier ensures all writes above are visible
                    // to the thread that reads with acquire semantics
                    state->ready_.store(true, std::memory_order_release);
                    handle.resume();
                }).detach();
            }

References kcenon::container::async::detail::async_awaitable< T >::state_.

operator=() [1/2]

template<typename T >

async_awaitable & kcenon::container::async::detail::async_awaitable< T >::operator= ( async_awaitable< T > && )

defaultnoexcept

operator=() [2/2]

template<typename T >

async_awaitable & kcenon::container::async::detail::async_awaitable< T >::operator= ( const async_awaitable< T > & )

delete

Member Data Documentation

state_

template<typename T >

std::shared_ptr<async_state<T> > kcenon::container::async::detail::async_awaitable< T >::state_

Definition at line 92 of file async_container.h.

Referenced by kcenon::container::async::detail::async_awaitable< T >::await_resume(), and kcenon::container::async::detail::async_awaitable< T >::await_suspend().

---

The documentation for this struct was generated from the following file:

• internal/async/async_container.h