Struct Executor 

pub struct Executor { /* private fields */ }

Task executor for synchronous task processing.

Provides a simple run-to-completion model where tasks are executed one at a time. Panics are caught to prevent runtime crashes.

Implementations

impl Executor

pub const fn new(work_queue: Arc<WorkQueue>) -> Self

Create a new executor with a shared work queue.

pub fn with_batch_size(self, size: usize) -> Self

Set the batch size for processing.

The batch size limits how many tasks are processed per tick() call.

pub fn tick(&mut self) -> usize

Process one tick (up to batch_size tasks).

Returns the total number of tasks processed (successful + failed).

pub fn execute_task(task: &mut Task) -> bool

Execute a single task with panic handling.

Returns true if the task completed successfully, false if it failed or panicked.

pub fn schedule(&self, task: Task) -> bool

Schedule a task for execution.

Returns false if the queue is full.

pub fn spawn<F>(&self, work: F) -> bool

where F: FnOnce() + Send + 'static,

Schedule work using a closure.

Convenience method that creates a task with normal priority.

pub const fn executed_count(&self) -> u64

Get the total number of successfully executed tasks.

pub const fn failed_count(&self) -> u64

Get the total number of failed tasks.

pub fn has_pending(&self) -> bool

Check if there’s pending work.

pub const fn batch_size(&self) -> usize

Get the current batch size.

pub fn drain(&mut self) -> usize

Drain all pending tasks, executing each one.

Returns the total number of tasks processed.

pub const fn reset_stats(&mut self)

Reset execution statistics.

Trait Implementations

impl Debug for Executor

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

Formats the value using the given formatter.