Thread.hpp

Go to the documentation of this file.

// The Reactive C++ Toolbox.
// Copyright (C) 2013-2019 Swirly Cloud Limited
// Copyright (C) 2021 Reactive Markets Limited
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#ifndef TOOLBOX_SYS_THREAD_HPP
#define TOOLBOX_SYS_THREAD_HPP
 
#include <toolbox/Config.h>
 
#include <functional>
#include <sched.h>
#include <string>
 
namespace toolbox {
inline namespace sys {
 
struct ThreadConfig {
    ThreadConfig(
        std::string name, std::string affinity = {}, std::string sched_policy = {},
        std::function<void()> init_fn = []() {}) noexcept
    : name{std::move(name)}
    , affinity{std::move(affinity)}
    , sched_policy{std::move(sched_policy)}
    , init_fn{std::move(init_fn)}
    {
    }
    ThreadConfig() noexcept = default;
    ~ThreadConfig() noexcept = default;
 
    // Copy.
    ThreadConfig(const ThreadConfig&) = default;
    ThreadConfig& operator=(const ThreadConfig&) = default;
 
    // Move.
    ThreadConfig(ThreadConfig&&) noexcept = default;
    ThreadConfig& operator=(ThreadConfig&&) noexcept = default;
 
    std::string name;
    std::string affinity;
    std::string sched_policy;
    std::function<void()> init_fn;
};
 
TOOLBOX_API cpu_set_t parse_cpu_set(std::string_view s) noexcept;
 
TOOLBOX_API int parse_sched_policy(std::string_view s);
 
TOOLBOX_API void set_thread_attrs(const ThreadConfig& config);
 
} // namespace sys
} // namespace toolbox
 
#endif // TOOLBOX_SYS_THREAD_HPP