rust
/
smol
mirror of https://github.com/stjepang/smol
1
0
Fork 0
Code Issues Releases Wiki Activity

Spawn blocking threads more eagerly

This commit is contained in:
Stjepan Glavina 2020-02-13 17:41:51 +01:00
parent 7247cdcffd
commit 205f1292c3
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/lib.rs
View File

@ -520,14 +520,15 @@ impl ThreadPool {
}
fn notify(&'static self, mut state: MutexGuard<'static, State>) {
if state.queue.len() > state.idle * 5 && state.threads < 500 {
if !state.queue.is_empty() {
self.cvar.notify_one();
}
while state.queue.len() > state.idle * 5 && state.threads < 500 {
state.idle += 1;
state.threads += 1;
self.cvar.notify_all();
drop(state);
thread::spawn(move || self.run());
} else if !state.queue.is_empty() {
self.cvar.notify_one();
}
}
}