JobSystem.h

Go to the documentation of this file.

 
#pragma once
 
#include "core/jobs/JobTypes.h"
 
#include <atomic>
#include <cstddef>
#include <memory>
#include <optional>
#include <string>
 
namespace core::ports::diagnostics {
class IErrorReporter;
}
 
namespace core::jobs {
 
class Scheduler;
class SlotLimiter;
 
class JobSystem {
public:
    explicit JobSystem(std::shared_ptr<core::ports::diagnostics::IErrorReporter> errorReporter,
              std::size_t workers = 0);

    ~JobSystem();

    JobSystem(const JobSystem&) = delete;

    JobSystem& operator=(const JobSystem&) = delete;

    JobSystem(JobSystem&& other) noexcept;

    JobSystem& operator=(JobSystem&& other) noexcept;

    [[nodiscard]] JobId submit(JobKind kind = JobKind::Generic);

    void start(const JobId& id);

    void publish(const JobEvent& event);

    void fail(const JobId& id, const std::string& error);

    void finish(const JobId& id);

    [[nodiscard]] std::shared_ptr<std::atomic<bool>> cancelFlag(const JobId& id) const;

    [[nodiscard]] std::shared_ptr<std::atomic<bool>> pauseFlag(const JobId& id) const;

    [[nodiscard]] Scheduler& scheduler();

    [[nodiscard]] SlotLimiter& slotLimiter();

    SubscriptionId subscribe(const JobId& id, JobEventCallback cb);

    void unsubscribe(const JobId& id, SubscriptionId subId);

    void cancel(const JobId& id);

    void pause(const JobId& id);

    void resume(const JobId& id);

    std::optional<JobSnapshot> snapshot(const JobId& id) const;

    void shutdown();
 
private:
    class Impl;
    std::unique_ptr<Impl> impl_;
};
 
}