Change: use the rayon crate for concurrency

1 files changed, 12 insertions, 3 deletions

diff --git a/src/main.rs b/src/main.rs
index e797b58..d49266b 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -2,21 +2,30 @@ extern crate chrono;
 extern crate crypto_hash;
 extern crate serde_yaml;
 extern crate walkdir;
+extern crate rayon;
 
 use std::env;
 use std::io;
 use std::collections::BTreeMap;
 use walkdir::{WalkDir, DirEntry};
+use rayon::prelude::*;
 
 mod format;
 
 
+type Map = BTreeMap<&'static str, String>;
+
+
 fn main() -> io::Result<()> {
     for dirname in env::args().skip(1) {
-        let maps = WalkDir::new(&dirname)
+        let maps: Vec<DirEntry> = WalkDir::new(&dirname)
             .into_iter()
             .filter_map(|e| e.ok())
-            .map(|e| mkmap(e));
+            .collect();
+        let maps: Vec<Map> = maps
+            .into_par_iter()
+            .map(mkmap)
+            .collect();
         for map in maps {
             println!("{}", serde_yaml::to_string(&map).unwrap());
         }
@@ -25,7 +34,7 @@ fn main() -> io::Result<()> {
 }
 
 
-fn mkmap(e: DirEntry) -> BTreeMap<&'static str, String> {
+fn mkmap(e: DirEntry) -> Map {
     let fields = vec![
         ("Name", format::name(&e)),
         ("Mtime", format::mtime(&e)),