fast-walker 0.0.0

use super::*;

impl WalkTaskQueue {
    pub fn new(depth_first: bool) -> Self {
        Self { tasks: Arc::new(Mutex::default()), depth_first }
    }
    pub fn send_roots(&self, paths: &[PathBuf]) {
        match self.tasks.lock() {
            Ok(mut o) => {
                o.extend(paths.iter().map(|p| (p.to_path_buf(), 0)));
            }
            Err(e) => {
                panic!("{:?}", e)
            }
        }
    }
    pub fn send(&self, path: &Path, depth: usize) -> bool {
        let path = match path.canonicalize() {
            Ok(o) => o,
            Err(_) => return false,
        };
        match self.tasks.lock() {
            Ok(mut o) => o.push_front((path, depth)),
            Err(_) => return false,
        }
        true
    }
    pub fn receive(&self) -> Option<(PathBuf, usize)> {
        match self.tasks.lock() {
            Ok(mut o) => {
                if self.depth_first {
                    o.pop_front()
                }
                else {
                    o.pop_back()
                }
            }
            Err(e) => {
                panic! { "{:?}", e }
            }
        }
    }
}