aging_typed_job.cpp

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2024, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#include <kcenon/thread/impl/typed_pool/aging_typed_job.h>
 
namespace kcenon::thread
{
    template <typename job_type>
    aging_typed_job_t<job_type>::aging_typed_job_t(
        job_type priority,
        std::function<common::VoidResult()> work,
        const std::string& name)
        : base(priority, name)
        , aged_priority_{priority, 0, std::chrono::steady_clock::now()}
        , work_(std::move(work))
    {
    }
 
    template <typename job_type>
    aging_typed_job_t<job_type>::~aging_typed_job_t() = default;
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::do_work() -> common::VoidResult
    {
        if (work_)
        {
            return work_();
        }
        return common::ok();
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::get_aged_priority() const
        -> const aged_priority<job_type>&
    {
        return aged_priority_;
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::get_aged_priority()
        -> aged_priority<job_type>&
    {
        return aged_priority_;
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::apply_boost(int boost_amount) -> void
    {
        aged_priority_.apply_boost(boost_amount, max_boost_);
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::reset_boost() -> void
    {
        aged_priority_.reset_boost();
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::set_max_boost(int max) -> void
    {
        max_boost_ = max;
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::get_max_boost() const -> int
    {
        return max_boost_;
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::is_max_boosted() const -> bool
    {
        return aged_priority_.is_max_boosted(max_boost_);
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::effective_priority() const -> job_type
    {
        return aged_priority_.effective_priority();
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::wait_time() const -> std::chrono::milliseconds
    {
        return aged_priority_.wait_time();
    }
 
    template <typename job_type>
    auto aging_typed_job_t<job_type>::to_job_info() const -> job_info
    {
        return job_info{
            this->get_name(),
            aged_priority_.wait_time(),
            aged_priority_.boost
        };
    }
 
    // Explicit template instantiation for job_types
    template class aging_typed_job_t<job_types>;
 
} // namespace kcenon::thread