aboutsummaryrefslogtreecommitdiff
path: root/evc/src/helpers/threading.rs
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-05-05 15:09:54 +0200
committermetamuffin <metamuffin@disroot.org>2025-05-05 15:09:54 +0200
commit306f96164784a8cbf405e72fa4364d6523366e95 (patch)
tree51717fc139871baa438aad806f4923669ae0896c /evc/src/helpers/threading.rs
parent9cc089e2d6e841879e430b01d2f3d92c8820523e (diff)
downloadvideo-codec-experiments-306f96164784a8cbf405e72fa4364d6523366e95.tar
video-codec-experiments-306f96164784a8cbf405e72fa4364d6523366e95.tar.bz2
video-codec-experiments-306f96164784a8cbf405e72fa4364d6523366e95.tar.zst
old dir
Diffstat (limited to 'evc/src/helpers/threading.rs')
-rw-r--r--evc/src/helpers/threading.rs26
1 files changed, 0 insertions, 26 deletions
diff --git a/evc/src/helpers/threading.rs b/evc/src/helpers/threading.rs
deleted file mode 100644
index 3291172..0000000
--- a/evc/src/helpers/threading.rs
+++ /dev/null
@@ -1,26 +0,0 @@
-use std::{
- sync::atomic::{AtomicUsize, Ordering},
- thread,
-};
-
-static THREADS_RUNNING: AtomicUsize = AtomicUsize::new(0);
-
-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) < max_threads {
- THREADS_RUNNING.fetch_add(1, Ordering::Relaxed);
-
- let o1h = thread::spawn(move || f1());
- let o2 = f2();
- let o1 = o1h.join().unwrap();
-
- THREADS_RUNNING.fetch_sub(1, Ordering::Relaxed);
- (o1, o2)
- } else {
- (f1(), f2())
- }
-}