Define thread pool size in some getter
This commit is contained in:
parent
05cacce192
commit
24017cd6f2
14
src/main.rs
14
src/main.rs
@ -47,6 +47,12 @@ fn main() -> ExitCode {
|
|||||||
ExitCode::FAILURE
|
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(
|
fn start_server(
|
||||||
path: PathBuf,
|
path: PathBuf,
|
||||||
address: &str,
|
address: &str,
|
||||||
@ -59,12 +65,8 @@ fn start_server(
|
|||||||
};
|
};
|
||||||
eprintln!("Strated server!");
|
eprintln!("Strated server!");
|
||||||
|
|
||||||
let context: Arc<Mutex<Context>> = Arc::default();
|
let context = Arc::new(Mutex::new(Context::default()));
|
||||||
|
let mut pool = ThreadPool::new(get_thread_pool_size());
|
||||||
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() {
|
for stream in listener.incoming() {
|
||||||
eprintln!("New connection!");
|
eprintln!("New connection!");
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user