Add threading support.

README.md

@@ -40,8 +40,8 @@ fn main() {
 ```
 
 # Roadmap
-- [ ] A single-thread blocking version
-- [ ] A thread pool version
+- [x] A single-thread blocking version
+- [x] A thread pool version
 - [ ] A non-blocking single-thread version
 - [ ] A complete HTTP/1 and HTTP/1.1 parser
 - [ ] TLS

example/Cargo.toml

@@ -4,5 +4,6 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
+clap = { version = "4.5.19", features = ["derive"] }
 http = { path = "../http" }
 

example/src/main.rs

@@ -1,3 +1,4 @@
+use clap::Parser;
 use http::{
     request::{Method, Request},
     response::{Headers, Response, Status},
@@ -55,7 +56,24 @@ fn headers(request: &mut Request) -> Response {
         },
     }
 }
+
+#[derive(Parser, Debug)]
+#[command(version, about, long_about = None)]
+struct Args {
+    /// Thread pool size (enable threading with --threading)
+    #[arg(short = 'c', long, default_value_t = 50)]
+    threads_count: usize,
+
+    #[arg(short, long)]
+    threaded: bool,
+}
+
 fn main() {
-    let server = Server::new("0.0.0.0:4000", headers);
+    let args = Args::parse();
+    let server = if args.threaded {
+        Server::threaded("0.0.0.0:4000", headers, args.threads_count)
+    } else {
+        Server::new("0.0.0.0:4000", headers)
+    };
     server.listen().unwrap();
 }

http/src/lib.rs

@@ -9,3 +9,4 @@
 pub mod request;
 pub mod response;
 pub mod server;
+pub mod threadpool;