Struct TaskManager 

pub struct TaskManager {
    tasks: HashMap<TaskId, RunningTask>,
    pending_import_rerun: Option<Option<usize>>,
}

Manages the lifecycle of background tasks.

The task manager spawns tasks in dedicated threads and provides methods to stop individual tasks or all tasks at once.

Fields

tasks: HashMap<TaskId, RunningTask>

pending_import_rerun: Option<Option<usize>>

A pending import rerun queued while an import was already running. Some(library_index) means re-run for that index after current finishes.

Implementations

impl TaskManager

pub fn new() -> Self

Creates a new empty task manager.

pub fn start( &mut self, task: Box<dyn BackgroundTask>, hub: Sender<Event>, ) -> Result<TaskId, TaskError>

Starts a background task in a new thread.

The task receives a clone of hub for sending events and a ShutdownSignal for graceful termination.

Returns an error if a task with the same ID is already running.

pub fn stop(&mut self, id: &TaskId) -> Result<(), TaskError>

Stops a running task by ID.

Sends the shutdown signal and waits for the task thread to finish. Returns an error if the task is not running.

pub fn stop_all(&mut self)

Stops all running tasks.

Sends shutdown signals to all tasks and waits for them to finish.

fn cleanup_finished(&mut self)

Removes entries for tasks whose threads have finished.

pub fn handle_event( &mut self, evt: &Event, hub: &Sender<Event>, database: &Database, settings: &Settings, ) -> bool

Observes an event without consuming it.

Must be called for every event before passing it to the view tree. Always returns false — it never consumes events.

fn schedule_import( &mut self, library_index: Option<usize>, hub: &Sender<Event>, database: &Database, settings: &Settings, )

Schedules an import task, coalescing if one is already running.

fn schedule_dictionary_index( &mut self, hub: &Sender<Event>, database: &Database, )

Schedules a dictionary index scan, stopping any running instance first.

pub fn is_running(&mut self, id: &TaskId) -> bool

Returns true if a task with the given ID is running.

pub fn running_tasks(&mut self) -> Vec<TaskId>

Returns the IDs of all running tasks.

Trait Implementations

impl Default for TaskManager

fn default() -> Self

Returns the “default value” for a type.

impl Drop for TaskManager

fn drop(&mut self)

Executes the destructor for this type.