wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added benchmark for delay(0) and yield().

This commit is contained in:
Steve Atherton 2022-10-30 20:26:11 -07:00
parent 65aeeff2a2
commit 34c61580a0
1 changed files with 29 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
flowbench/BenchNet2.actor.cpp
View File

@ -20,6 +20,7 @@
#include "benchmark/benchmark.h"
#include "flow/IRandom.h"
#include "flow/flow.h"
#include "flow/DeterministicRandom.h"
#include "flow/network.h"
@ -61,3 +62,31 @@ static void bench_net2(benchmark::State& benchState) {
}
BENCHMARK(bench_net2)->Range(1, 1 << 16)->ReportAggregatesOnly(true);
ACTOR static Future<Void> benchDelayActor(benchmark::State* benchState, bool useYield) {
// Number of random delays to start to just to populate the run loop
// priority queue
state int64_t timerCount = benchState->range(0);
state std::vector<Future<Void>> futures;
state DeterministicRandom rand(platform::getRandomSeed());
while (--timerCount > 0) {
futures.push_back(delay(1.0 + rand.random01(), getRandomTaskPriority(rand)));
}
while (benchState->KeepRunning()) {
wait(useYield ? yield() : delay(0));
}
benchState->SetItemsProcessed(static_cast<long>(benchState->iterations() + timerCount));
return Void();
}
static void bench_delay(benchmark::State& benchState) {
onMainThread([&benchState] { return benchDelayActor(&benchState, false); }).blockUntilReady();
}
static void bench_yield(benchmark::State& benchState) {
onMainThread([&benchState] { return benchDelayActor(&benchState, true); }).blockUntilReady();
}
BENCHMARK(bench_delay)->Range(0, 1 << 16)->ReportAggregatesOnly(true);
BENCHMARK(bench_yield)->Range(0, 1 << 16)->ReportAggregatesOnly(true);