Allow thread pool size configuration

2025-04-16 22:00:54 +02:00 · 2025-04-16 22:00:54 +02:00 · 5b975a23f8
commit 5b975a23f8
parent 8fd751304c
1 changed files with 5 additions and 1 deletions
--- a/src/main.rs
+++ b/src/main.rs
@ -62,7 +62,11 @@ fn start_server(
    eprintln!("Strated server!");

    let context: Arc<Mutex<Context>> = Arc::default();
-    let mut pool = ThreadPool::new(4);
+
+    let thread_pool_size = std::env::var("THREAD_POOL")
+        .map(|s| s.parse().unwrap_or(4))
+        .unwrap_or(4);
+    let mut pool = ThreadPool::new(thread_pool_size);

    for stream in listener.incoming() {
        eprintln!("New connection!");