[][src]Crate bigqueue

A big, fast and persistent queue based on memory mapped file.

let mut q = BigQueue::new(&"/tmp/bigqueue", true).unwrap();

let total = 10000;
let data = b"1234567890abcdefghij";

for _a in 0..total {
    q.push(data).unwrap();
}

let mut count = 0;
loop {
    let pop_data = q.pop();
    if  pop_data.is_ok() && pop_data.unwrap().len() == data.len() {
        count = count + 1;
    } else {
        println!("count {}", count);
        break;
    }
}
fs::create_dir_all(PathBuf::from("/tmp/spsc")).expect("create dir error");
if let Ok((mut tx, mut rx)) = bigqueue::channel("/tmp/spsc", true){
    let v = b"1234567890abcdefghij";
    let total = 100000000;
    let t = thread::spawn(move|| {
        for _i in 0..total {
            tx.enqueue(v).unwrap();
        }
    });

    let two_sec = Duration::from_secs(2);
    thread::sleep(two_sec);

    let start = PreciseTime::now();
    let mut count = 0;
    loop{
        if rx.dequeue().is_ok() {
            count = count + 1;

        }
        if count == total {
            println!("count {}", count);
            break;
        }

    }
    let end = PreciseTime::now();
    println!("{} seconds for enqueue and dequeue. {} ps", start.to(end), total*1000000/start.to(end).num_microseconds().unwrap());
    t.join().unwrap();
}

Structs

BigQueue
Config
Receiver
Sender

Enums

Error

Functions

channel