thread.hpp

Go to the documentation of this file.

/**
 * @file
 * @copyright
 * (c) Copyright ESO 2024
 * All Rights Reserved
 * ESO (eso.org) is an Intergovernmental Organisation, and therefore special legal conditions apply.
 */
#ifndef NUMAPP_DETAIL_THREAD_HPP
#define NUMAPP_DETAIL_THREAD_HPP
 
#include <condition_variable>
#include <functional>
#include <mutex>
 
#include <numapp/numapolicies.hpp>
 
namespace numapp::detail {
 
template <bool>
struct TokenPrepender;
 
template <>
struct TokenPrepender<true> {
    template <class Func, class... Args>
    static auto Bind(Func&& func, Args&&... args) {
        return std::bind(std::forward<Func>(func), std::placeholders::_1, std::forward<Args>(args)...);
    }
};
 
template <>
struct TokenPrepender<false> {
    template <class Func, class... Args>
    static auto Bind(Func&& func, Args&&... args) {
        return std::bind(std::forward<Func>(func), std::forward<Args>(args)...);
    }
};
 
class ThreadInitializer {
public:
    ThreadInitializer(std::string_view name, NumaPolicies const& policies);
 
    /**
     * Wait for Initialize() to complete.
     */
    auto Wait() -> std::system_error const&;
 
    /**
     * Setup calling thread according to provided policies.
     */
    auto Initialize() -> std::error_code;
 
private:
    std::string_view m_name;
    NumaPolicies const& m_policies;
 
    std::optional<std::system_error> m_result;
    std::condition_variable m_cond;
    std::mutex m_mtx;
    /**
     * Lock used by thread owning ThreadInitializer which invokes Wait()
     */
    std::unique_lock<std::mutex> m_lck;
};
 
}  // namespace numapp::detail
 
#endif  // NUMAPP_DETAIL_THREAD_HPP