job_queue_adapter.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/thread/interfaces/pool_queue_adapter.h>
#include <kcenon/thread/core/job_queue.h>
 
namespace kcenon::thread {
 
class job_queue_adapter : public pool_queue_adapter_interface {
public:
    explicit job_queue_adapter(std::shared_ptr<job_queue> queue)
        : queue_(std::move(queue)) {}
 
    job_queue_adapter()
        : queue_(std::make_shared<job_queue>()) {}
 
    ~job_queue_adapter() override = default;
 
    // Non-copyable
    job_queue_adapter(const job_queue_adapter&) = delete;
    job_queue_adapter& operator=(const job_queue_adapter&) = delete;
 
    // Movable
    job_queue_adapter(job_queue_adapter&&) = default;
    job_queue_adapter& operator=(job_queue_adapter&&) = default;
 
    [[nodiscard]] auto enqueue(std::unique_ptr<job>&& j) -> common::VoidResult override {
        return queue_->enqueue(std::move(j));
    }
 
    [[nodiscard]] auto enqueue_batch(std::vector<std::unique_ptr<job>>&& jobs) -> common::VoidResult override {
        return queue_->enqueue_batch(std::move(jobs));
    }
 
    [[nodiscard]] auto dequeue() -> common::Result<std::unique_ptr<job>> override {
        return queue_->dequeue();
    }
 
    [[nodiscard]] auto try_dequeue() -> common::Result<std::unique_ptr<job>> override {
        return queue_->try_dequeue();
    }
 
    [[nodiscard]] auto empty() const -> bool override {
        return queue_->empty();
    }
 
    [[nodiscard]] auto size() const -> std::size_t override {
        return queue_->size();
    }
 
    auto clear() -> void override {
        queue_->clear();
    }
 
    auto stop() -> void override {
        queue_->stop();
    }
 
    [[nodiscard]] auto is_stopped() const -> bool override {
        return queue_->is_stopped();
    }
 
    [[nodiscard]] auto get_capabilities() const -> queue_capabilities override {
        return queue_->get_capabilities();
    }
 
    [[nodiscard]] auto to_string() const -> std::string override {
        return queue_->to_string();
    }
 
    [[nodiscard]] auto get_job_queue() const -> std::shared_ptr<job_queue> override {
        return queue_;
    }
 
    [[nodiscard]] auto get_scheduler() -> scheduler_interface& override {
        return *queue_;
    }
 
    [[nodiscard]] auto get_scheduler() const -> const scheduler_interface& override {
        return *queue_;
    }
 
private:
    std::shared_ptr<job_queue> queue_;
};
 
} // namespace kcenon::thread