Skip to main content

spawn

ai_memory::background::offload_ttl_sweep

Function spawn 

Source 
pub fn spawn<T>(state: Arc<Mutex<T>>, interval: Duration) -> JoinHandle<()>
where
    T: SweepAdapter + Send + 'static,
Expand description

Spawn the daily sweep loop. Returns a JoinHandle the caller aborts on shutdown.

The state lock is held only for the duration of each pass; the in-pass std::thread::sleep between deletes happens INSIDE that lock window, which is acceptable because the sweep is a single background thread and not a hot data-plane path. v0.8.0 may move the per-row sleep outside the lock if the offload write volume grows.