utilities/fd
utilities/fd
1
0
Fork 0
mirror of https://github.com/sharkdp/fd synced 2024-10-01 13:33:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use non-sync channel

Browse source
This commit is contained in:
David Peter 2021-11-26 19:43:36 +01:00 committed by David Peter
parent e990a13405
commit f219da4b3a
1 changed files with 2 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/walk.rs
View file

@ -3,7 +3,7 @@ use std::fs::{FileType, Metadata};
use std::io;
use std::path::{Path, PathBuf};
use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::mpsc::{sync_channel, Receiver, SyncSender as Sender};
use std::sync::mpsc::{channel, Receiver, Sender};
use std::sync::{Arc, Mutex};
use std::thread;
use std::time;
@ -22,12 +22,6 @@ use crate::exit_codes::{merge_exitcodes, ExitCode};
use crate::filesystem;
use crate::output;
pub const WORKER_CHANNEL_DEFAULT_BOUND: usize = 1000;
pub fn make_worker_channel() -> (Sender<WorkerResult>, Receiver<WorkerResult>) {
sync_channel(WORKER_CHANNEL_DEFAULT_BOUND)
}
/// The receiver thread can either be buffering results or directly streaming to the console.
enum ReceiverMode {
/// Receiver is still buffering in order to sort the results, if the search finishes fast
@ -59,7 +53,7 @@ pub fn scan(path_vec: &[PathBuf], pattern: Arc<Regex>, config: Arc<Config>) -> R
let first_path_buf = path_iter
.next()
.expect("Error: Path vector can not be empty");
let (tx, rx) = make_worker_channel();
let (tx, rx) = channel();
let mut override_builder = OverrideBuilder::new(first_path_buf.as_path());