thread_pool_adapter.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <kcenon/pacs/integration/thread_pool_interface.h>
 
#include <cstddef>
#include <memory>
#include <mutex>
 
namespace kcenon::thread {
class thread_pool;
}  // namespace kcenon::thread
 
namespace kcenon::pacs::integration {
 
class thread_pool_adapter final : public thread_pool_interface {
public:
    // =========================================================================
    // Constructors
    // =========================================================================
 
    explicit thread_pool_adapter(const thread_pool_config& config);
 
    explicit thread_pool_adapter(std::shared_ptr<kcenon::thread::thread_pool> pool);
 
    ~thread_pool_adapter() override;
 
    // =========================================================================
    // Non-copyable, Non-movable
    // =========================================================================
 
    thread_pool_adapter(const thread_pool_adapter&) = delete;
    thread_pool_adapter& operator=(const thread_pool_adapter&) = delete;
    thread_pool_adapter(thread_pool_adapter&&) = delete;
    thread_pool_adapter& operator=(thread_pool_adapter&&) = delete;
 
    // =========================================================================
    // Lifecycle Management (from thread_pool_interface)
    // =========================================================================
 
    [[nodiscard]] auto start() -> bool override;
    [[nodiscard]] auto is_running() const noexcept -> bool override;
    void shutdown(bool wait_for_completion = true) override;
 
    // =========================================================================
    // Task Submission (from thread_pool_interface)
    // =========================================================================
 
    [[nodiscard]] auto submit(std::function<void()> task)
        -> std::future<void> override;
 
    [[nodiscard]] auto submit_with_priority(
        job_priority priority,
        std::function<void()> task) -> std::future<void> override;
 
    void submit_fire_and_forget(std::function<void()> task) override;
 
    // =========================================================================
    // Statistics (from thread_pool_interface)
    // =========================================================================
 
    [[nodiscard]] auto get_thread_count() const -> std::size_t override;
    [[nodiscard]] auto get_pending_task_count() const -> std::size_t override;
    [[nodiscard]] auto get_idle_worker_count() const -> std::size_t override;
 
    // =========================================================================
    // Adapter-specific Methods
    // =========================================================================
 
    [[nodiscard]] auto get_underlying_pool() const
        -> std::shared_ptr<kcenon::thread::thread_pool>;
 
    [[nodiscard]] auto get_config() const noexcept -> const thread_pool_config&;
 
private:
    std::shared_ptr<kcenon::thread::thread_pool> pool_;
    thread_pool_config config_;
    mutable std::mutex mutex_;
    bool initialized_{false};
 
    void submit_internal(std::function<void()> task, job_priority priority);
};
 
}  // namespace kcenon::pacs::integration