execution_handler_sequential.hpp

Go to the documentation of this file.

// -----------------------------------------------------------------------------------------------------
// Copyright (c) 2006-2021, Knut Reinert & Freie Universität Berlin
// Copyright (c) 2016-2021, Knut Reinert & MPI für molekulare Genetik
// This file may be used, modified and/or redistributed under the terms of the 3-clause BSD-License
// shipped with this file and also available at: https://github.com/seqan/seqan3/blob/master/LICENSE.md
// -----------------------------------------------------------------------------------------------------
 
#pragma once
 
#include <seqan3/std/concepts>
#include <seqan3/std/ranges>
 
#include <seqan3/core/platform.hpp>
 
namespace seqan3::detail
{
 
struct execution_handler_sequential
{
public:
 
    template <typename algorithm_t, typename algorithm_input_t, typename callback_t>
        requires std::invocable<algorithm_t, algorithm_input_t, callback_t>
    void execute(algorithm_t && algorithm, algorithm_input_t && input, callback_t && callback)
    {
        algorithm(std::forward<algorithm_input_t>(input), std::forward<callback_t>(callback));
    }
 
    template <std::copy_constructible algorithm_t,
              std::ranges::input_range algorithm_input_range_t,
              std::copy_constructible callback_t>
        requires std::invocable<algorithm_t, std::ranges::range_reference_t<algorithm_input_range_t>, callback_t>
    void bulk_execute(algorithm_t && algorithm, algorithm_input_range_t && input_range, callback_t && callback)
    {
        for (auto && input : input_range)
            execute(algorithm, std::forward<decltype(input)>(input), callback);
 
        wait();
    }
 
    void wait() noexcept
    {
        // noop
    }
};
 
} // namespace seqan3