bjoernager/rust
bjoernager/rust
1
Fork 0
Code Activity

Tune drop_excess_capacity

Browse source
This commit is contained in:
bjorn3 2022-08-24 12:22:01 +02:00
parent f71c545746
commit 293223d0cf
1 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/concurrency_limiter.rs
View file

@ -152,14 +152,14 @@ mod state {
fn drop_excess_capacity(&mut self) {
self.assert_invariants();
if self.active_jobs == self.pending_jobs {
// Drop all excess tokens
self.tokens.truncate(std::cmp::max(self.active_jobs, 1));
} else {
// Keep some excess tokens to satisfy requests faster
const MAX_EXTRA_CAPACITY: usize = 2;
self.tokens.truncate(std::cmp::max(self.active_jobs + MAX_EXTRA_CAPACITY, 1));
}
// Drop all tokens that can never be used anymore
self.tokens.truncate(std::cmp::max(self.pending_jobs, 1));
// Keep some excess tokens to satisfy requests faster
const MAX_EXTRA_CAPACITY: usize = 2;
self.tokens.truncate(std::cmp::max(self.active_jobs + MAX_EXTRA_CAPACITY, 1));
self.assert_invariants();
}
}