Struct TokioExecutor 

pub struct TokioExecutor { /* private fields */ }

Async I/O executor using tokio tasks with concurrency limit.

Optimized for I/O-bound operations (network, disk, async operations). Available in all deployments (tokio is standard dependency).

Implementations

impl TokioExecutor

pub fn new(max_concurrent: usize) -> Self

Create new Tokio executor with concurrency limit.

Arguments

• max_concurrent - Maximum number of concurrent async tasks

Trait Implementations

impl ConcurrencyExecutor for TokioExecutor

fn execute_batch<'life0, 'async_trait, F, T>( &'life0 self, items: Vec<T>, op: F, ) -> Pin<Box<dyn Future<Output = Result<Vec<Result<(), ExecutionError>>, ExecutionError>> + Send + 'async_trait>>

where F: Fn(T) -> Result<(), ExecutionError> + Send + Sync + 'static + 'async_trait, T: Send + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Execute operation on batch of items concurrently.

fn name(&self) -> &str

Get executor implementation name for debugging.

impl Debug for TokioExecutor

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

Formats the value using the given formatter.