Source code
Revision control
Copy as Markdown
Other Tools
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);