Struct cros_async::common_executor::RawExecutor

pub struct RawExecutor<Re: Reactor + 'static> {
    pub reactor: Re,
    queue: RunnableQueue,
    blocking_pool: BlockingPool,
    state: AtomicI32,
    detached_tasks: Mutex<DetachedTasks>,
}

Fields

reactor: Re

queue: RunnableQueue

blocking_pool: BlockingPool

state: AtomicI32

detached_tasks: Mutex<DetachedTasks>

Implementations

impl<Re: Reactor> RawExecutor<Re>

pub fn new_with(reactor: Re) -> AsyncResult<Arc<Self>>

pub fn new() -> AsyncResult<Arc<Self>>

fn wake(&self)

fn run_internal<F: Future>( &self, cx: &mut Context<'_>, done: F ) -> AsyncResult<F::Output>

Trait Implementations

impl<Re: Reactor + AsRawDescriptors> AsRawDescriptors for RawExecutor<Re>

fn as_raw_descriptors(&self) -> Vec<RawDescriptor>

Returns the underlying raw descriptors.

impl<Re: Reactor> Drop for RawExecutor<Re>

fn drop(&mut self)

Executes the destructor for this type.

impl<Re: Reactor> WeakWake for RawExecutor<Re>

fn wake_by_ref(weak_self: &Weak<Self>)

fn wake(weak_self: Weak<Self>)