dispatcher_pool.h

Go to the documentation of this file.

 
#pragma once
 
#include <cstdint>
#include <memory>
#include <vector>
 
#include "contur/dispatch/i_dispatch_runtime.h"
#include "contur/tracing/trace_event.h"
 
namespace contur {

    class DispatcherPool final : public IDispatchRuntime
    {
        public:
        explicit DispatcherPool(HostThreadingConfig config = {});

        ~DispatcherPool() override;

        DispatcherPool(const DispatcherPool &) = delete;

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

        DispatcherPool &operator=(DispatcherPool &&) noexcept;

        [[nodiscard]] std::string_view name() const noexcept override;

        [[nodiscard]] const HostThreadingConfig &config() const noexcept override;

        [[nodiscard]] Result<void> dispatch(const DispatcherLanes &lanes, std::size_t tickBudget) override;

        void tick(const DispatcherLanes &lanes) override;

        [[nodiscard]] std::uint64_t lastEpoch() const noexcept;

        [[nodiscard]] std::vector<std::size_t> lastDeterministicOrder() const;

        [[nodiscard]] std::vector<TraceEvent> lastTraceEvents() const;
 
        private:
        struct Impl;
        std::unique_ptr<Impl> impl_;
    };
 
} // namespace contur