worker_statistics.hpp

Go to the documentation of this file.

#pragma once

 
#include <chrono>
#include <cstdint>
#include <vector>
 
#include "orrery/core/aligned_allocator.hpp"
 
namespace orrery::backend {

using Clock = std::chrono::steady_clock;

using Duration = std::chrono::nanoseconds;

struct WorkerStatistics {
    std::uint64_t chunks{};

    std::uint64_t items{};

    std::uint64_t steals{};

    Duration busy{};

    Duration idle{};
};

struct alignas(core::kCacheLineBytes) PaddedWorkerStatistics {
    WorkerStatistics value;
};

struct ExecutorStatistics {
    std::vector<WorkerStatistics> workers;

    Duration elapsed{};

    std::uint64_t regions{};

    [[nodiscard]] Duration busy() const noexcept {
        Duration total{};
        for (const WorkerStatistics& worker : workers) {
            total += worker.busy;
        }
        return total;
    }

    [[nodiscard]] Duration idle() const noexcept {
        Duration total{};
        for (const WorkerStatistics& worker : workers) {
            total += worker.idle;
        }
        return total;
    }

    [[nodiscard]] double idle_fraction() const noexcept {
        const Duration total = busy() + idle();
        if (total.count() == 0) {
            return 0.0;
        }
        return static_cast<double>(idle().count()) / static_cast<double>(total.count());
    }
};
 
} // namespace orrery::backend