protected_job.h

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.
 
#pragma once
 
#include <kcenon/common/resilience/circuit_breaker.h>
#include <kcenon/thread/core/job.h>
 
#include <memory>
 
namespace kcenon::thread
{
    using common::resilience::circuit_breaker;
 
    class protected_job : public job
    {
    public:
        protected_job(
            std::unique_ptr<job> inner,
            std::shared_ptr<circuit_breaker> cb);
 
        ~protected_job() override;
 
        auto do_work() -> common::VoidResult override;
 
        [[nodiscard]] auto get_name() const -> std::string;
 
    private:
        std::unique_ptr<job> inner_;
        std::shared_ptr<circuit_breaker> cb_;
    };
 
} // namespace kcenon::thread