static_executor.hpp

Go to the documentation of this file.

#pragma once

 
#include <cstdint>
#include <string_view>
#include <vector>
 
#include "orrery/backend/cpu_topology.hpp"
#include "orrery/backend/executor.hpp"
#include "orrery/backend/thread_pool.hpp"
#include "orrery/backend/worker_statistics.hpp"
#include "orrery/core/types.hpp"
 
namespace orrery::backend {

class StaticExecutor final : public Executor {
public:
    explicit StaticExecutor(unsigned worker_count = 0,
                            ThreadPool::Affinity affinity = ThreadPool::Affinity::kUnpinned);
 
    void run(core::Index count, RangeTask task) override;
 
    [[nodiscard]] std::string_view name() const noexcept override { return "static"; }
 
    [[nodiscard]] unsigned worker_count() const noexcept override { return pool_.worker_count(); }
 
    [[nodiscard]] CoreClass worker_core_class(unsigned worker) const noexcept override {
        return pool_.core_class(worker);
    }
 
    [[nodiscard]] ExecutorStatistics statistics() const override;
 
    void reset_statistics() noexcept override;
 
private:
    ThreadPool pool_;

    std::vector<PaddedWorkerStatistics> workers_;

    std::vector<Duration> busy_at_region_start_;
 
    Duration elapsed_{};
    std::uint64_t regions_{};
};
 
} // namespace orrery::backend