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

Remove duplicate spawn definition

Browse source
This commit is contained in:
Aode (Lion) 2022-02-11 16:09:37 -06:00
parent 72c50bcaf6
commit b1d60cc8cd
1 changed files with 1 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
src/lib.rs
View file

@ -430,29 +430,7 @@ impl Runner {
&self,
future: impl Future<Output = T> + Send + 'static,
) -> JoinHandle<T> {
let mut guard = self.state.lock().unwrap();
let task = guard
.pop_available_head()
.unwrap_or_else(|| Task::allocate(self.inner.next_task_id()));
guard.pending.insert(task.task_id, Arc::clone(&task));
let (tx, rx) = oneshot();
*task.fut.lock().unwrap() = Some(Box::pin(async move {
let _ = tx.send(future.await);
}));
guard.wake(task);
guard.spawn_count += 1;
if guard.should_heuristic_unpark() {
if let Some(thread) = self.inner.parked.lock().unwrap().pop_front() {
thread.unpark();
}
guard.update_unpark();
}
JoinHandle { rx }
self.state.lock().unwrap().spawn(&self.inner, future)
}
fn block_on<T: Send + 'static>(