safe-async/jitterbug
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

formatting changes

Browse source
This commit is contained in:
Aode (Lion) 2022-01-29 20:59:10 -06:00
parent 39240b4a50
commit ec7e40a309
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/lib.rs
View file

@ -11,6 +11,9 @@ use std::{
time::{Duration, Instant},
};
const PRUNE_SPAWN_COUNT: u64 = 1000;
const PRUNE_DURATION: Duration = Duration::from_secs(5);
enum OneshotState<T> {
New,
Waker(Waker),
@ -236,9 +239,6 @@ struct Inner {
prune_time: Instant,
}
const SPAWN_COUNT: u64 = 1000;
const PRUNE_DURATION: Duration = Duration::from_secs(5);
impl Inner {
fn take_available_head(&mut self) -> Option<Arc<Task>> {
let head = self.head_available.take()?;
@ -253,7 +253,8 @@ impl Inner {
}
fn heuristic_prune(&mut self) {
if self.spawn_count > SPAWN_COUNT || self.prune_time + PRUNE_DURATION < Instant::now() {
if self.spawn_count > PRUNE_SPAWN_COUNT || self.prune_time + PRUNE_DURATION < Instant::now()
{
self.prune();
}
}
@ -409,14 +410,18 @@ impl Executor {
if let Poll::Ready(res) = Pin::new(&mut join_handle).poll(&mut block_on_context) {
return res;
}
self.heuristic_prune();
}
if let Poll::Ready(res) = Pin::new(&mut join_handle).poll(&mut block_on_context) {
return res;
}
if self.stopping() {
return Err(JoinError);
}
self.park();
}
}