scheduler.h

Go to the documentation of this file.

 
#pragma once
 
#include <memory>
 
#include "contur/scheduling/i_scheduler.h"
 
namespace contur {
 
    class ITracer;

    class Scheduler final : public IScheduler
    {
        public:
        explicit Scheduler(std::unique_ptr<ISchedulingPolicy> policy, ITracer &tracer);

        ~Scheduler() override;

        Scheduler(const Scheduler &) = delete;

        Scheduler &operator=(const Scheduler &) = delete;
        Scheduler(Scheduler &&) noexcept;

        Scheduler &operator=(Scheduler &&) noexcept;

        [[nodiscard]] Result<void> enqueue(PCB &pcb, Tick currentTick) override;

        [[nodiscard]] Result<void> dequeue(ProcessId pid) override;

        [[nodiscard]] Result<ProcessId> selectNext(const IClock &clock) override;

        [[nodiscard]] Result<void> blockRunning(Tick currentTick) override;

        [[nodiscard]] Result<void> blockProcess(ProcessId pid, Tick currentTick) override;

        [[nodiscard]] Result<void> unblock(ProcessId pid, Tick currentTick) override;

        [[nodiscard]] Result<void> terminate(ProcessId pid, Tick currentTick) override;

        [[nodiscard]] std::vector<ProcessId> getQueueSnapshot() const override;

        [[nodiscard]] std::vector<ProcessId> getBlockedSnapshot() const override;

        [[nodiscard]] Result<void> configureLanes(std::size_t laneCount) override;

        [[nodiscard]] std::size_t laneCount() const noexcept override;

        [[nodiscard]] Result<void> enqueueToLane(PCB &pcb, std::size_t laneIndex, Tick currentTick) override;

        [[nodiscard]] Result<ProcessId> selectNextForLane(std::size_t laneIndex, const IClock &clock) override;

        [[nodiscard]] Result<ProcessId> stealNextForLane(std::size_t thiefLane, const IClock &clock) override;

        [[nodiscard]] std::vector<std::vector<ProcessId>> getPerLaneQueueSnapshot() const override;

        [[nodiscard]] std::vector<ProcessId> runningProcesses() const override;

        [[nodiscard]] Result<void> setPolicy(std::unique_ptr<ISchedulingPolicy> policy) override;

        [[nodiscard]] std::string_view policyName() const noexcept override;
 
        private:
        struct Impl;
        std::unique_ptr<Impl> impl_;
    };
 
} // namespace contur