feat: add sys limit

README.md

@@ -5,6 +5,12 @@ Manage concurrent tasks with optional limits, cancellation, and first-error prop
 
 Inpired by golang (errgroups)
 
+## Disclaimer
+
+The library is still new, and as such the API is subject to change, I don't expect changes to the add and wait functions, but the rest may change. I might also move to custom error types, and or removing the tokio_utils entirely to slim down the package. It shouldn't affect the user too much however.
+
+The crate is in production, and has seen extensive use
+
 ## Features
 
 - **Unlimited or bounded concurrency** via `with_limit(usize)`.  
@@ -104,6 +110,6 @@ See [LICENSE-MIT](LICENSE-MIT) and [LICENSE-APACHE](LICENSE-APACHE) for details.
 
 ## Contribute
 
-Simply create an issue here or pr https://github.com/kjuulh/noworkers.git, development happens publicly at: git.front.kjuulh.io/kjuulh/noworkers.
+Simply create an issue here or pr https://github.com/kjuulh/noworkers.git, development happens publicly at: https://git.front.kjuulh.io/kjuulh/noworkers.
 
 

crates/noworkers/src/lib.rs

@@ -3,6 +3,24 @@ use std::{future::Future, sync::Arc};
 use tokio::{sync::Mutex, task::JoinHandle};
 use tokio_util::sync::CancellationToken;
 
+pub mod extensions {
+    use crate::Workers;
+
+    pub trait WithSysLimitCpus {
+        fn with_limit_to_system_cpus(&mut self) -> &mut Self;
+    }
+
+    impl WithSysLimitCpus for Workers {
+        fn with_limit_to_system_cpus(&mut self) -> &mut Self {
+            self.with_limit(
+                std::thread::available_parallelism()
+                    .expect("to be able to get system cpu info")
+                    .into(),
+            )
+        }
+    }
+}
+
 type ErrChan = Arc<
     Mutex<(
         Option<tokio::sync::oneshot::Sender<anyhow::Error>>,