Lines Matching refs:task
25 use std::task::{Context, Poll, Waker};
41 pub struct AbortOnDropJoinHandle<T>(tokio::task::JoinHandle<T>);
61 type Target = tokio::task::JoinHandle<T>;
67 fn deref_mut(&mut self) -> &mut tokio::task::JoinHandle<T> { in deref_mut()
71 impl<T> From<tokio::task::JoinHandle<T>> for AbortOnDropJoinHandle<T> {
72 fn from(jh: tokio::task::JoinHandle<T>) -> Self { in from()
91 let j = with_ambient_tokio_runtime(|| tokio::task::spawn(f)); in spawn()
100 let j = with_ambient_tokio_runtime(|| tokio::task::spawn_blocking(f)); in spawn_blocking()
150 tokio::task::yield_now().await; in in_tokio()
184 let mut task = Context::from_waker(Waker::noop()); in poll_noop() localVariable
185 match future.poll(&mut task) { in poll_noop()