From a713143ef9c1187c37004043b1d3322d773f9ea0 Mon Sep 17 00:00:00 2001 From: metamuffin Date: Tue, 6 Dec 2022 22:16:50 +0100 Subject: webm + variable amount of threads --- evc/src/threading.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'evc/src/threading.rs') diff --git a/evc/src/threading.rs b/evc/src/threading.rs index 012b5bf..3291172 100644 --- a/evc/src/threading.rs +++ b/evc/src/threading.rs @@ -5,13 +5,13 @@ use std::{ static THREADS_RUNNING: AtomicUsize = AtomicUsize::new(0); -pub fn both_par(f1: F1, f2: F2) -> (O1, O2) +pub fn both_par(f1: F1, f2: F2, max_threads: usize) -> (O1, O2) where F1: FnOnce() -> O1 + Send + 'static, O1: Send + 'static, F2: FnOnce() -> O2, { - if THREADS_RUNNING.load(Ordering::Relaxed) < 12 { + if THREADS_RUNNING.load(Ordering::Relaxed) < max_threads { THREADS_RUNNING.fetch_add(1, Ordering::Relaxed); let o1h = thread::spawn(move || f1()); -- cgit v1.2.3-70-g09d2