makeThreadExample2.cpp

Go to the documentation of this file.

/**
 * @file
 * @copyright
 *   SPDX-FileCopyrightText: 2023-2023 European Southern Observatory (ESO)
 *
 *   SPDX-License-Identifier: LGPL-3.0-only
 */
#include <numapp/memory.hpp>
#include <numapp/thread.hpp>
 
template <class F, class... Args>
auto MakePinnedThread(int cpu, std::string_view name, F&& f, Args... args) -> std::thread {
    using namespace numapp;
 
    NumaPolicies policies;
    policies.SetCpuAffinity(CpuAffinity::MakeBindCpu(cpu));
    auto node = GetNodeOfCpu(cpu);
    if (!node.has_value()) {
        throw std::invalid_argument("cpu invalid");
    }
    policies.SetMemPolicy(MemPolicy::MakeBindNode(*node));
    return MakeThread(name, policies, std::forward<F>(f), std::forward<Args>(args)...);
}