Struct sunrise_libuser::futures::WaitableManager

pub struct WaitableManager<'a> {
    work_queue: WorkQueue<'a>,
    registry: Arena<Task<'a>>,
}

The event loop manager. Waits on the waitable objects added to it.

Fields

work_queue: WorkQueue<'a>

Queue of things to do in the next "tick" of the event loop.

registry: Arena<Task<'a>>

List of futures that are currently running on this executor.

Implementations

impl<'a> WaitableManager<'a>

pub fn new() -> WaitableManager<'a>

Creates an empty event loop.

pub fn work_queue(&self) -> WorkQueue<'a>

Returns a handle to the underlying WorkQueue backing this event loop. Can (and probably should be) passed to futures spawned on the event loop so they can wait on handles and spawn new futures themselves.

pub fn run(&mut self)

Runs the event loop, popping items from the underlying WorkQueue and executing them. When there isn't any more work to do, we call syscalls::wait_synchronization() on all the handles that were registered through WorkQueue#WaitHandle. All the tasks that were waiting on the handle that got woken up will be polled again, resuming the event loop.

Returns when all the futures spawned on the loop have returned a value.

Trait Implementations

impl<'a> Debug for WaitableManager<'a>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'a> Default for WaitableManager<'a>

fn default() -> Self

Returns the "default value" for a type.