From 24017cd6f2e3eeb5df903509e5e2915e372d7fac Mon Sep 17 00:00:00 2001
From: p11 <Krapohl.f@gmx.de>
Date: Thu, 29 May 2025 20:17:01 +0200
Subject: [PATCH] Define thread pool size in some getter

---
 src/main.rs | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 702d158..27f899e 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -47,6 +47,12 @@ fn main() -> ExitCode {
     ExitCode::FAILURE
 }
 
+fn get_thread_pool_size() -> usize {
+    std::env::var("THREAD_POOL")
+        .map(|s| s.parse().unwrap_or(4))
+        .unwrap_or(4)
+}
+
 fn start_server(
     path: PathBuf,
     address: &str,
@@ -59,12 +65,8 @@ fn start_server(
     };
     eprintln!("Strated server!");
 
-    let context: Arc<Mutex<Context>> = Arc::default();
-
-    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);
+    let context = Arc::new(Mutex::new(Context::default()));
+    let mut pool = ThreadPool::new(get_thread_pool_size());
 
     for stream in listener.incoming() {
         eprintln!("New connection!");