executor_integration.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <kcenon/logger/core/thread_integration_detector.h>
#include <kcenon/logger/integration/standalone_executor.h>
#include <kcenon/logger/logger_export.h>
 
#if LOGGER_HAS_IEXECUTOR
 
#if __has_include(<kcenon/common/interfaces/executor_interface.h>)
#include <kcenon/common/interfaces/executor_interface.h>
#elif __has_include(<common/interfaces/executor_interface.h>)
#include <common/interfaces/executor_interface.h>
#endif
 
#include <atomic>
#include <functional>
#include <memory>
#include <mutex>
#include <string>
 
namespace kcenon::logger::integration {
 
enum class executor_type {
    none,
 
    standalone,
 
    external
};
 
class LOGGER_SYSTEM_API executor_integration {
public:
    static void enable(std::shared_ptr<common::interfaces::IExecutor> executor = nullptr);
 
    static void disable();
 
    [[nodiscard]] static bool is_enabled() noexcept;
 
    [[nodiscard]] static executor_type get_executor_type() noexcept;
 
    static void set_executor(std::shared_ptr<common::interfaces::IExecutor> executor);
 
    [[nodiscard]] static std::shared_ptr<common::interfaces::IExecutor> get_executor() noexcept;
 
    [[nodiscard]] static bool submit_task(std::function<void()> task);
 
    [[nodiscard]] static bool submit_task_delayed(
        std::function<void()> task,
        std::chrono::milliseconds delay_ms);
 
    [[nodiscard]] static std::string get_executor_name() noexcept;
 
    [[nodiscard]] static size_t pending_tasks() noexcept;
 
    [[nodiscard]] static size_t worker_count() noexcept;
 
private:
    // Prevent instantiation - all methods are static
    executor_integration() = delete;
    ~executor_integration() = delete;
    executor_integration(const executor_integration&) = delete;
    executor_integration& operator=(const executor_integration&) = delete;
 
    // Internal state
    static std::atomic<executor_type> current_type_;
    static std::shared_ptr<common::interfaces::IExecutor> executor_;
    static std::mutex executor_mutex_;
 
    static std::shared_ptr<common::interfaces::IExecutor> create_default_executor();
};
 
[[nodiscard]] constexpr bool has_executor_support() noexcept {
    return true;
}
 
} // namespace kcenon::logger::integration
 
#else // !LOGGER_HAS_IEXECUTOR
 
namespace kcenon::logger::integration {
 
class executor_integration {
public:
    static void enable() noexcept {}
    static void disable() noexcept {}
    [[nodiscard]] static constexpr bool is_enabled() noexcept { return false; }
    [[nodiscard]] static bool submit_task(std::function<void()>) noexcept { return false; }
    [[nodiscard]] static std::string get_executor_name() noexcept { return "none"; }
 
private:
    executor_integration() = delete;
};
 
[[nodiscard]] constexpr bool has_executor_support() noexcept {
    return false;
}
 
} // namespace kcenon::logger::integration
 
#endif // LOGGER_HAS_IEXECUTOR