barrier.hpp

/**
 * @file
 * @copyright
 *   SPDX-FileCopyrightText: 2022-2024 European Southern Observatory (ESO)
 
 *   SPDX-License-Identifier: LGPL-3.0-only
 */
#ifndef ION_DETAIL_BARRIER_HPP
#define ION_DETAIL_BARRIER_HPP
 
#include <ion/detail/macros.hpp>
 
namespace ion::detail {
 
struct NoOp {};
 
template <class CompletionFunction>
class BarrierBase;
template <>
class BarrierBase<NoOp> {
public:
    BarrierBase(NoOp&& f) {
    }
};
 
template <class CompletionFunction>
class BarrierBase {
public:
    static_assert(std::is_nothrow_invocable_v<CompletionFunction&>, "");
    BarrierBase(CompletionFunction&& f) : m_completion(std::forward<CompletionFunction>(f)) {
    }
 
protected:
    ION_FORCE_INLINE inline void Complete() noexcept {
        m_completion();
    };
 
private:
    CompletionFunction m_completion;
};
 
template <class CompletionFunction>
//  NOLINTNEXTLINE(readability-identifier-naming)
constexpr bool IsNoOp =
    std::is_same_v<detail::NoOp, std::remove_cv_t<std::remove_reference_t<CompletionFunction>>>;
 
template <class F>
ION_FORCE_INLINE inline void Invoke(F&& f) {
    if constexpr (!IsNoOp<F>) {
        f();
    }
}
 
}  // namespace ion::detail
#endif  // ION_DETAIL_BARRIER_HPP