diff options
| author | metamuffin <metamuffin@disroot.org> | 2022-12-06 22:16:50 +0100 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2022-12-06 22:16:50 +0100 |
| commit | a713143ef9c1187c37004043b1d3322d773f9ea0 (patch) | |
| tree | b5d390a77fa6428d0648d9446a75978f85fdbb5f /evc/src/threading.rs | |
| parent | 39cb075c7f58e78899be43ca9ad4d65837f53a26 (diff) | |
| download | video-codec-experiments-a713143ef9c1187c37004043b1d3322d773f9ea0.tar video-codec-experiments-a713143ef9c1187c37004043b1d3322d773f9ea0.tar.bz2 video-codec-experiments-a713143ef9c1187c37004043b1d3322d773f9ea0.tar.zst | |
webm + variable amount of threads
Diffstat (limited to 'evc/src/threading.rs')
| -rw-r--r-- | evc/src/threading.rs | 4 |
1 files changed, 2 insertions, 2 deletions
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, F2, O1, O2>(f1: F1, f2: F2) -> (O1, O2) +pub fn both_par<F1, F2, O1, O2>(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()); |