Struct EventLoopGroup 

pub struct EventLoopGroup { /* private fields */ }

An event loop group collects one or more EventLoops together for processor affiniity and load balancing purposes

Implementations

impl EventLoopGroup

pub fn new_default( allocator: &Allocator, max_threads: Option<u16>, on_shutdown: impl FnOnce() + Send + 'static, ) -> Result<EventLoopGroup, Error>

Create a new default EventLoopGroup. max_threads: use None for the CRT default on_shutdown will be called when the event loop group shuts down.

pub fn get_next_loop(&self) -> Result<EventLoop, Error>

Get the next event loop to schedule a task on. (Internally, the CRT will make a choice on which loop in the group will be returned.)

pub fn get_loop_count(&self) -> usize

Get the number of loops in this group.

Trait Implementations

impl Clone for EventLoopGroup

fn clone(&self) -> EventLoopGroup

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EventLoopGroup

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Drop for EventLoopGroup

fn drop(&mut self)

Executes the destructor for this type.

impl Spawn for EventLoopGroup

fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError>

Spawns a future that will be run to completion.

fn status(&self) -> Result<(), SpawnError>

Determines whether the executor is able to spawn new tasks.

impl TaskScheduler for EventLoopGroup

Scheduling a task on an EventLoopGroup first finds the next EventLoop to use (as reported by the CRT), then uses that one to run the Task.

fn schedule_task_now(&self, task: Task) -> Result<(), Error>

Schedule a Task to run as soon as possible. If the task is cancelled, it will be called with TaskStatus::Canceled as an argument.

impl Send for EventLoopGroup

impl Sync for EventLoopGroup