disk-queue 0.1.1

FIFO queue backed by disk
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use std::path::Path;

use criterion::{criterion_group, criterion_main, Criterion, Throughput};

use disk_queue::DiskQueue;

const BENCHMARK_DB_PATH: &str = "benchmark.db";

fn cleanup_benchmark_db() {
    loop {
        std::fs::remove_file(BENCHMARK_DB_PATH).unwrap();
        if !Path::new(BENCHMARK_DB_PATH).exists() {
            break;
        }
        std::thread::sleep(std::time::Duration::from_millis(1));
    }
}

fn write(c: &mut Criterion) {
    let disk_queue = DiskQueue::open(BENCHMARK_DB_PATH);

    let record = "record".as_bytes().to_vec();

    let mut group = c.benchmark_group("write");
    group.throughput(Throughput::Elements(1));
    group.bench_function("enqueue", |b| b.iter(|| disk_queue.enqueue(record.clone())));
    group.finish();

    cleanup_benchmark_db();
}

criterion_group!(benches, write);
criterion_main!(benches);