Struct CircularBuffer 

pub struct CircularBuffer<O, A> { /* private fields */ }

A fixed-capacity circular replay buffer.

Stores experience tuples and overwrites the oldest when full. Implements rl_traits::ReplayBuffer so it’s usable by any algorithm that depends on that trait, not just DQN.

Implementation notes

Uses a Vec pre-allocated to capacity with a write cursor that wraps around. This avoids any allocation after construction and gives O(1) push and O(batch_size) sample.

Implementations

impl<O: Clone + Send + Sync, A: Clone + Send + Sync> CircularBuffer<O, A>

pub fn new(capacity: usize) -> Self

Trait Implementations

impl<O, A> ReplayBuffer<O, A> for CircularBuffer<O, A>

where O: Clone + Send + Sync, A: Clone + Send + Sync,

fn push(&mut self, experience: Experience<O, A>)

Add a new experience to the buffer.

fn sample(&self, batch_size: usize, rng: &mut impl Rng) -> Vec<Experience<O, A>>

Sample a random batch of batch_size experiences.

fn len(&self) -> usize

The number of experiences currently stored.

fn capacity(&self) -> Option<usize>

The maximum number of experiences the buffer can hold, if bounded.

fn is_empty(&self) -> bool

Returns true if the buffer contains no experiences.

fn is_full(&self) -> bool

Returns true if the buffer is at capacity.

fn ready_for(&self, batch_size: usize) -> bool

Returns true if the buffer has enough experience to sample a batch of the given size.