Struct tokio::runtime::task::list::LocalOwnedTasks

pub(crate) struct LocalOwnedTasks<S: 'static> {
    inner: UnsafeCell<OwnedTasksInner<S>>,
    pub(crate) id: NonZeroU64,
    _not_send_or_sync: PhantomData<*const ()>,
}

Fields

inner: UnsafeCell<OwnedTasksInner<S>>

id: NonZeroU64

_not_send_or_sync: PhantomData<*const ()>

Implementations

impl<S: 'static> LocalOwnedTasks<S>

pub(crate) fn new() -> Self

pub(crate) fn bind<T>( &self, task: T, scheduler: S, id: Id, ) -> (JoinHandle<T::Output>, Option<Notified<S>>)

where S: Schedule, T: Future + 'static, T::Output: 'static,

pub(crate) fn close_and_shutdown_all(&self)

where S: Schedule,

Shuts down all tasks in the collection. This call also closes the collection, preventing new items from being added.

pub(crate) fn remove(&self, task: &Task<S>) -> Option<Task<S>>

pub(crate) fn assert_owner(&self, task: Notified<S>) -> LocalNotified<S>

Asserts that the given task is owned by this LocalOwnedTasks and convert it to a LocalNotified, giving the thread permission to poll this task.

fn with_inner<F, T>(&self, f: F) -> T

where F: FnOnce(&mut OwnedTasksInner<S>) -> T,

pub(crate) fn is_closed(&self) -> bool

pub(crate) fn is_empty(&self) -> bool