Struct AsyncTask

pub struct AsyncTask<P: AsyncTaskPoolExt<O> + AsyncTaskPool<O>, O: Default + 'static = ()> { /* private fields */ }

异步任务

Implementations

impl<P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>, O: Default + 'static> AsyncTask<P, O>

pub fn new( uid: TaskId, pool: Arc<P>, priority: usize, future: Option<BoxFuture<'static, O>>, ) -> AsyncTask<P, O>

构建单线程任务

pub fn with_context<C: 'static>( uid: TaskId, pool: Arc<P>, priority: usize, future: Option<BoxFuture<'static, O>>, context: C, ) -> AsyncTask<P, O>

使用指定上下文构建单线程任务

pub fn with_runtime_and_context<RT, C>( runtime: &RT, priority: usize, future: Option<BoxFuture<'static, O>>, context: C, ) -> AsyncTask<P, O>

where RT: AsyncRuntime<O, Pool = P>, C: Send + 'static,

使用指定异步运行时和上下文构建单线程任务

pub fn is_enable_wakeup(&self) -> bool

检查是否允许唤醒

pub fn get_inner(&self) -> Option<BoxFuture<'static, O>>

获取内部任务

pub fn set_inner(&self, inner: Option<BoxFuture<'static, O>>)

设置内部任务

pub fn owner(&self) -> usize

获取任务的所有者

pub fn priority(&self) -> usize

获取异步任务优先级

pub fn exist_context(&self) -> bool

pub fn get_context<C: Send + 'static>(&self) -> Option<&C>

pub fn get_context_mut<C: Send + 'static>(&self) -> Option<&mut C>

pub fn set_context<C: Send + 'static>(&self, new: C)

pub fn get_pool(&self) -> &P

Trait Implementations

impl<P: AsyncTaskPoolExt<O> + AsyncTaskPool<O, Pool = P>, O: Default + 'static> ArcWake for AsyncTask<P, O>

fn wake_by_ref(arc_self: &Arc<Self>)

Indicates that the associated task is ready to make progress and should be polled.

fn wake(self: Arc<Self>)

Indicates that the associated task is ready to make progress and should be polled.

impl<P: AsyncTaskPoolExt<O> + AsyncTaskPool<O>, O: Default + 'static> Drop for AsyncTask<P, O>

fn drop(&mut self)

Executes the destructor for this type.

impl<P: AsyncTaskPoolExt<O> + AsyncTaskPool<O>, O: Default + 'static> Send for AsyncTask<P, O>

impl<P: AsyncTaskPoolExt<O> + AsyncTaskPool<O>, O: Default + 'static> Sync for AsyncTask<P, O>