config.h

Go to the documentation of this file.

#pragma once
 
// BSD 3-Clause License
// Copyright (c) 2024, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#include <cstddef>
#include <chrono>
 
namespace kcenon::thread::config {
    
    // Thread management configuration
    constexpr size_t default_thread_count = 4;
    constexpr size_t max_threads = 64;
    constexpr size_t min_threads = 1;
    
    // Queue configuration
    constexpr size_t default_queue_size = 1024;
    constexpr size_t unlimited_queue_size = 0;
    
    // Timing configuration
    constexpr auto default_wake_interval = std::chrono::milliseconds(100);
    constexpr auto default_shutdown_timeout = std::chrono::seconds(5);
    constexpr auto default_worker_idle_timeout = std::chrono::seconds(30);
    
    // Performance configuration
    constexpr bool default_yield_on_idle = true;
 
#ifdef THREAD_WORK_STEALING_ENABLED
    constexpr bool default_work_stealing = true;
#else
    constexpr bool default_work_stealing = false;
#endif
 
    // Work-stealing tuning parameters
 
    constexpr size_t default_max_steal_attempts = 3;
 
    constexpr auto default_steal_backoff = std::chrono::microseconds(50);
 
    constexpr bool default_pin_threads = false;
    constexpr bool default_use_priorities = false;
    
    // Resource limits
    constexpr size_t max_queue_size = 1024 * 1024; // 1M jobs max
    constexpr size_t default_stack_size = 1024 * 1024; // 1MB stack
    
    // Feature flags
    constexpr bool enable_coroutines = __cplusplus >= 202002L;
    constexpr bool enable_statistics = true;
    constexpr bool enable_debugging = false;
    
    // Thread naming
    constexpr const char* default_thread_prefix = "worker";
    constexpr const char* default_pool_name = "thread_pool";
    
    static_assert(default_thread_count >= min_threads, "Thread count must be at least minimum");
    static_assert(default_thread_count <= max_threads, "Thread count must not exceed maximum");
    static_assert(default_queue_size > 0 || default_queue_size == unlimited_queue_size, 
                  "Queue size must be positive or unlimited");
    static_assert(max_queue_size > default_queue_size, "Max queue size must exceed default");
    
} // namespace kcenon::thread::config