Struct TaskScheduler 

pub struct TaskScheduler { /* private fields */ }

Simple task scheduler for managing async operations

Implementations

impl TaskScheduler

pub fn new(max_concurrent_tasks: usize) -> Self

Creates a new task scheduler with specified concurrency limit

Parameters

• max_concurrent_tasks: Maximum number of concurrent tasks

pub async fn schedule_task<F, T>(&self, task: F) -> Result<T, GraphRAGError>

where F: Future<Output = Result<T, GraphRAGError>>,

Schedules and executes an async task

In production, this would implement proper task queuing and scheduling. Currently executes tasks immediately.

Parameters

• task: Future to execute

Returns

Result of the task execution

pub fn max_concurrent_tasks(&self) -> usize

Returns the maximum number of concurrent tasks allowed

Trait Implementations

impl Debug for TaskScheduler

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

Formats the value using the given formatter.