80 lines
2.7 KiB
Rust
80 lines
2.7 KiB
Rust
use criterion::{black_box, criterion_group, criterion_main, Criterion};
|
|
use triple_buffer::TripleBuffer;
|
|
|
|
pub fn benchmark(c: &mut Criterion) {
|
|
let (mut input, mut output) = TripleBuffer::<u8>::default().split();
|
|
|
|
{
|
|
let mut uncontended = c.benchmark_group("uncontended");
|
|
uncontended.bench_function("read output", |b| b.iter(|| *output.output_buffer()));
|
|
uncontended.bench_function("clean update", |b| {
|
|
b.iter(|| {
|
|
output.update();
|
|
})
|
|
});
|
|
uncontended.bench_function("clean receive", |b| b.iter(|| *output.read()));
|
|
uncontended.bench_function("write input", |b| {
|
|
b.iter(|| {
|
|
*input.input_buffer() = black_box(0);
|
|
})
|
|
});
|
|
uncontended.bench_function("publish", |b| {
|
|
b.iter(|| {
|
|
input.publish();
|
|
})
|
|
});
|
|
uncontended.bench_function("send", |b| b.iter(|| input.write(black_box(0))));
|
|
uncontended.bench_function("publish + dirty update", |b| {
|
|
b.iter(|| {
|
|
input.publish();
|
|
output.update();
|
|
})
|
|
});
|
|
uncontended.bench_function("transmit", |b| {
|
|
b.iter(|| {
|
|
input.write(black_box(0));
|
|
*output.read()
|
|
})
|
|
});
|
|
}
|
|
|
|
{
|
|
let mut read_contended = c.benchmark_group("read contention");
|
|
testbench::run_under_contention(
|
|
|| black_box(*output.read()),
|
|
|| {
|
|
read_contended.bench_function("write input", |b| {
|
|
b.iter(|| {
|
|
*input.input_buffer() = black_box(0);
|
|
})
|
|
});
|
|
read_contended.bench_function("publish", |b| {
|
|
b.iter(|| {
|
|
input.publish();
|
|
})
|
|
});
|
|
read_contended.bench_function("send", |b| b.iter(|| input.write(black_box(0))));
|
|
},
|
|
);
|
|
}
|
|
|
|
{
|
|
let mut write_contended = c.benchmark_group("write contention");
|
|
testbench::run_under_contention(
|
|
|| input.write(black_box(0)),
|
|
|| {
|
|
write_contended
|
|
.bench_function("read output", |b| b.iter(|| *output.output_buffer()));
|
|
write_contended.bench_function("update", |b| {
|
|
b.iter(|| {
|
|
output.update();
|
|
})
|
|
});
|
|
write_contended.bench_function("receive", |b| b.iter(|| *output.read()));
|
|
},
|
|
);
|
|
}
|
|
}
|
|
|
|
criterion_group!(benches, benchmark);
|
|
criterion_main!(benches);
|