Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Many reth components require to spawn tasks for long-running jobs. For example discovery spawns tasks to handle egress and ingress of udp traffic or network that spawns session tasks that handle the traffic to and from a peer.

To unify how tasks are created, the TaskManager provides access to the configured Tokio runtime. A TaskManager stores the [tokio::runtime::Handle] it is associated with. In this way it is possible to configure on which runtime a task is executed.

The main purpose of this type is to be able to monitor if a critical task panicked, for diagnostic purposes, since tokio task essentially fail silently. Therefore, this type is a Stream that yields the name of panicked task, See TaskExecutor::spawn_critical. In order to execute Tasks use the TaskExecutor type TaskManager::executor.

Implementations

impl TaskManager

pub fn current() -> Self

Returns a new TaskManager over the currently running Runtime.

This must be polled for the duration of the program.

To obtain the current TaskExecutor see TaskExecutor::current.

Panics

This will panic if called outside the context of a Tokio runtime.

pub fn new(handle: Handle) -> Self

Create a new instance connected to the given handle’s tokio runtime.

This also sets the global TaskExecutor.

pub fn executor(&self) -> TaskExecutor

Returns a new TaskExecutor that can spawn new tasks onto the tokio runtime this type is connected to.

pub fn graceful_shutdown(self)

Fires the shutdown signal and awaits until all tasks are shutdown.

pub fn graceful_shutdown_with_timeout(self, timeout: Duration) -> bool

Fires the shutdown signal and awaits until all tasks are shutdown.

Returns true if all tasks were shutdown before the timeout elapsed.

Trait Implementations

impl Debug for TaskManager

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

Formats the value using the given formatter.

impl Future for TaskManager

An endless future that resolves if a critical task panicked.

See TaskExecutor::spawn_critical

type Output = Result<(), PanickedTaskError>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 72 bytes