round_robin_executor.h

Go to the documentation of this file.

 
#pragma once
 
#include <emlabcpp/algorithm.h>
#include <emlabcpp/pmr/memory_resource.h>
#include <emlabcpp/static_circular_buffer.h>
 
namespace emlabcpp::coro
{
template < typename Container >
typename Container::value_type round_robin_run( pmr::memory_resource&, Container coros )
{
        std::size_t i = 0;
 
        while ( true ) {
 
                auto& cor = coros[i];
                i         = ( i + 1 ) % std::size( coros );
 
                if ( cor.done() ) {
                        if ( i == 0 && all_of( coros ) )
                                co_return;
                        continue;
                }
 
                auto const* out = cor.get_request();
 
                if ( out == nullptr )
                        co_return;
 
                auto resp = co_yield *out;
                cor.store_reply( resp );
 
                if ( !cor.tick() )
                        co_return;
        }
}
 
}  // namespace emlabcpp::coro