Struct DefaultExecutor 

pub struct DefaultExecutor { /* private fields */ }

Creates a Tokio [Runtime] for use with CPU bound tasks

Tokio forbids dropping Runtimes in async contexts, so creating a separate Runtime correctly is somewhat tricky. This structure manages the creation and shutdown of a separate thread.

Notes

On drop, the thread will wait for all remaining tasks to complete.

Depending on your application, more sophisticated shutdown logic may be required, such as ensuring that no new tasks are added to the runtime.

Credits

This code is derived from code originally written for InfluxDB 3.0

Implementations

impl DefaultExecutor

pub fn new() -> Self

Create a new Tokio Runtime for CPU bound tasks

pub fn handle(&self) -> &Handle

Return a handle suitable for spawning CPU bound tasks

Notes

If a task spawned on this handle attempts to do IO, it will error with a message such as:

A Tokio 1.x context was found, but IO is disabled.

Trait Implementations

impl Debug for DefaultExecutor

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

Formats the value using the given formatter.

impl Default for DefaultExecutor

fn default() -> Self

Returns the “default value” for a type.

impl DistExecutor for DefaultExecutor

fn handle(&self) -> &Handle

impl Drop for DefaultExecutor

fn drop(&mut self)

Executes the destructor for this type.