rsdb 0.12.1

a flash-sympathetic persistent lock-free B+ tree, pagecache, and log
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::sync::Arc;
use std::sync::atomic::AtomicBool;
use std::sync::atomic::Ordering::SeqCst;
use std::thread;
use std::time::Duration;

use super::*;

pub fn flusher(
    name: String,
    iob: Arc<IoBufs>,
    shutdown: Arc<AtomicBool>,
    flush_every_ms: u64,
) -> std::io::Result<thread::JoinHandle<()>> {
    thread::Builder::new().name(name).spawn(move || while
        !shutdown.load(SeqCst)
    {
        iob.flush();
        thread::sleep(Duration::from_millis(flush_every_ms));
    })
}