CodeMirror/czkawka
1
0
Fork 0
mirror of synced 2024-05-19 11:53:43 +12:00
Code Issues Projects Releases Wiki Activity

Simple multithreading

Browse source
This commit is contained in:
Rafał Mikrut 2023-05-03 17:31:21 +02:00
parent 147715d628
commit 6df46cbca5
1 changed files with 25 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
czkawka_core/src/same_music.rs
View file

@ -723,23 +723,33 @@ impl SameMusic {
continue;
}
let mut similar_fingerprints = Vec::new();
for e_entry in &self.music_entries[f_idx + 1..] {
let e_string = e_entry.path.to_string_lossy().to_string();
if used_paths.contains(&e_string) {
continue;
let mut collected_similar_items = self.music_entries[f_idx + 1..]
.par_iter()
.filter_map(|e_entry| {
let e_string = e_entry.path.to_string_lossy().to_string();
if used_paths.contains(&e_string) {
return None;
}
let mut segments = match_fingerprints(&f_entry.fingerprint, &e_entry.fingerprint, configuration).unwrap();
segments.retain(|s| s.duration(configuration) > minimum_segment_duration && s.score < maximum_difference);
if segments.is_empty() {
None
} else {
Some((e_string, e_entry))
}
})
.collect::<Vec<_>>();
collected_similar_items.retain(|(path, _entry)| !used_paths.contains(path));
if !collected_similar_items.is_empty() {
let mut music_entries = Vec::new();
for (path, entry) in collected_similar_items {
used_paths.insert(path);
music_entries.push(entry.clone());
}
let mut segments = match_fingerprints(&f_entry.fingerprint, &e_entry.fingerprint, configuration).unwrap();
segments.retain(|s| s.duration(configuration) > minimum_segment_duration && s.score < maximum_difference);
if !segments.is_empty() {
similar_fingerprints.push(e_entry.clone());
used_paths.insert(e_string);
}
}
if !similar_fingerprints.is_empty() {
used_paths.insert(f_string);
similar_fingerprints.push(f_entry.clone());
duplicated_music_entries.push(similar_fingerprints);
music_entries.push(f_entry.clone());
duplicated_music_entries.push(music_entries);
}
}
Some(duplicated_music_entries)