Method Run

phxqueue/comm/utils/benchmark_util.cpp:154–176

}

void BenchMark::Run()
{
    printf("qps: %d\n", impl_->qps);
    printf("nthread: %d\n", impl_->nthread);
    printf("nroutine: %d\n", impl_->nroutine);
    printf("routine_sleep_time(ms): %d\n", impl_->routine_sleep_time_ms);
    printf("start run...\n");

    impl_->stats.reset(new StatData[impl_->nthread]);

    for (int i{0}; i < impl_->nthread; ++i) {
        pthread_t tid;
        pthread_create(&tid, 0, ThreadRunFunc, new ThreadRunFuncArgs_t{i, this});
        pthread_detach(tid);
    }

    // stat
    gettimeofday(&impl_->last_stat_time, nullptr);
    while (true) {
        std::this_thread::sleep_for(std::chrono::seconds(10));
        ResStat();
    }
}

int BenchMark::GetRoutineSleepTimeMS() {
    return impl_->routine_sleep_time_ms;