Struct ProjectedFactorCache 

pub struct ProjectedFactorCache { /* private fields */ }

Memoizer for projected factor products keyed on a (design, factor) fingerprint.

Implementations

impl ProjectedFactorCache

pub const DEFAULT_BUDGET_BYTES: usize

pub fn with_budget(budget_bytes: usize) -> Self

pub fn get_or_insert_with( &self, key: ProjectedFactorKey, compute: impl FnOnce() -> Array2<f64>, ) -> Arc<Array2<f64>>

pub fn len(&self) -> usize

pub fn total_bytes(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn wait_for_subscriber( &self, key: ProjectedFactorKey, timeout: Duration, ) -> bool

Test/diagnostic affordance: block until a consumer has subscribed to the in-progress slot for key (i.e. is waiting on the producer), or until timeout elapses. Returns true if a subscriber arrived, false if the key has no in-progress slot or the wait timed out.

This lives on the cache because it reaches into the per-key subscriber condvar and waiter counter, which are private synchronization internals; exposing it as a method keeps those fields encapsulated while still letting downstream tests deterministically order producer/consumer interleavings.

Trait Implementations

impl Default for ProjectedFactorCache

fn default() -> Self

Returns the “default value” for a type.