Struct Threshold 

pub struct Threshold {
    pub threshold_bytes: usize,
    pub head_reserve_bytes: usize,
    /* private fields */
}

A threshold-based SpillPolicy: when a queue’s resident-byte count exceeds head_reserve_bytes + threshold_bytes, spill all entries past the head reserve (except the last entry, which stays as the try_merge target).

Fields

threshold_bytes: usize

Spillable surplus: spill is considered when resident bytes exceed head_reserve_bytes + threshold_bytes.

head_reserve_bytes: usize

Bytes near the head of the queue stay resident, protecting the consumer from an immediate page-in stall.

Implementations

impl Threshold

pub fn new(strategy: Box<dyn BytesSpill>) -> Threshold

Create a new threshold policy with default knobs, dispatching spills through strategy.

Trait Implementations

impl SpillPolicy for Threshold

fn apply(&mut self, queue: &mut VecDeque<QueueEntry>)

Optionally transforms some (ranges of) queue entries.