Class ThreadBarrier

test/test_helpers.hpp:97–120

Thread barrier for synchronizing multiple threads

// Thread barrier for synchronizing multiple threads
class ThreadBarrier {
public:
    explicit ThreadBarrier(size_t count) : threshold(count), count(count), generation(0) {}
    
    void wait() {
        std::unique_lock<std::mutex> lock(mutex);
        auto gen = generation;
        
        if (--count == 0) {
            generation++;
            count = threshold;
            cond.notify_all();
        } else {
            cond.wait(lock, [this, gen] { return gen != generation; });
        }
    }
    
private:
    std::mutex mutex;
    std::condition_variable cond;
    size_t threshold;
    size_t count;
    size_t generation;
};

// Calculate expected statistics for a series of sleep times
struct ExpectedStats {