makeThreadExample3.cpp

Go to the documentation of this file.

/**
 * @file
 * @copyright
 *   SPDX-FileCopyrightText: 2026-2026 European Southern Observatory (ESO)
 *
 *   SPDX-License-Identifier: LGPL-3.0-only
 */
#include <chrono>
#include <iostream>
#include <numapp/numa.hpp>
#include <numapp/thread.hpp>
 
struct Example {
    Example(std::chrono::milliseconds duration) : m_duration(duration) {
    }
    Example(Example&&) = default;
 
    void ThreadFunc() {
        std::cout << "Thread affinity: "
                  << numapp::CpuAffinity::MakeFromActive() << std::endl;
 
        std::this_thread::sleep_for(m_duration);
    }
    std::chrono::milliseconds m_duration;
};
 
int main() {
    using namespace numapp;
    using namespace std::chrono_literals;
    if (!NumaAvailable()) {
        std::cout << "NUMA not available";
        return -1;
    }
 
    NumaPolicies policies;
    policies.SetCpuAffinity(CpuAffinity::MakeFromCpuStringAll("0-3"));
    auto thread =
        MakeJthread("myThread", policies, &Example::ThreadFunc, Example{500ms});
}