Struct ReusableBlockPool

pub struct ReusableBlockPool {
    queue: BlockPool<Block>,
    num_workers: usize,
}

A non-block single-linked list to store blocks.

Fields

queue: BlockPool<Block>

num_workers: usize

Implementations

impl ReusableBlockPool

pub fn new(num_workers: usize) -> Self

Create empty block list

pub fn len(&self) -> usize

Get number of blocks in this list.

pub fn push(&self, block: Block)

Add a block to the list.

pub fn pop(&self) -> Option<Block>

Pop a block out of the list.

pub fn reset(&mut self)

Clear the list.

pub fn iterate_blocks(&self, f: impl FnMut(Block))

Iterate all the blocks in the queue. Call the visitor for each reported block.

pub fn flush_all(&self)

Flush the block queue