process files in parallel

2 files changed, 22 insertions, 18 deletions

diff --git a/src/files.rs b/src/files.rs
index 25592de..fbeaba0 100644
--- a/src/files.rs
+++ b/src/files.rs
@@ -20,9 +20,10 @@ use failure::Error;
 use rayon::{ThreadPool, ThreadPoolBuilder};
 use alphanumeric_sort::compare_str;
 use mime_guess;
+use rayon::prelude::*;
 
 use pathbuftools::PathBufTools;
-use async_value::{Async, Stale};
+use async_value::{Async, Stale, StopIter};
 
 use crate::fail::{HResult, HError, ErrorLog};
 use crate::dirty::{AsyncDirtyBit, DirtyBit, Dirtyable};
@@ -339,17 +340,13 @@ impl Files {
 
         let files: Vec<_> = direntries?
             .into_iter()
+            .stop_stale(stale.clone())
+            .par_bridge()
             .map(|file| {
-                if stale.is_stale().ok()? {
-                    None
-                } else {
-                    let file = File::new_from_direntry(file,
-                                                       Some(dirty_meta.clone()));
-                    Some(file)
-                }
+                let file = File::new_from_direntry(file,
+                                                   Some(dirty_meta.clone()));
+                file
             })
-            .fuse()
-            .flatten()
             .collect();
 
         if stale.is_stale()? {
@@ -620,16 +617,21 @@ impl Files {
     }
 
     pub fn meta_all_sync(&mut self) -> HResult<()> {
-        let mut same = true;
+        let same = Mutex::new(true);
 
-        for file in self.iter_files_mut() {
-            if !file.meta_processed {
-                file.meta_sync().log();
-                same = false;
-            }
-        }
+        self.iter_files_mut()
+            .par_bridge()
+            .for_each(|f| {
+                if !f.meta_processed {
+                    f.meta_sync().log();
+                    same.lock()
+                        .map(|mut t| *t = false)
+                        .map_err(HError::from)
+                        .log();
+                }
+            });
 
-        if !same {
+        if !*same.lock()? {
             self.set_dirty();
         }
 
diff --git a/src/listview.rs b/src/listview.rs
index 4222787..6084f98 100644
--- a/src/listview.rs
+++ b/src/listview.rs
@@ -3,6 +3,7 @@ use std::path::{Path, PathBuf};
 
 use termion::event::Key;
 use unicode_width::UnicodeWidthStr;
+use rayon::prelude::*;
 
 use async_value::{Stale, StopIter};
 
@@ -352,6 +353,7 @@ impl FileListBuilder {
             .iter_files_mut()
             .skip(from)
             .take(upto)
+            .par_bridge()
             .for_each(|f| f.meta_sync().log());
         view.content.meta_upto = Some(view.content.len);