Struct parallel_processor::execution_manager::packet::PacketsPool

pub struct PacketsPool<T: Sync + Send + 'static> { /* private fields */ }

Implementations

impl<T: PacketTrait> PacketsPool<T>

pub fn new(
    cap: usize,
    init_data: T::InitData,
    mem_tracker: &Arc<MemoryTrackerManager>
) -> Self

pub async fn alloc_packet(&self) -> Packet<T>

pub fn set_size(&self, new_size: usize)

pub fn alloc_packet_blocking(&self) -> Packet<T>

pub fn get_available_items(&self) -> i64

Trait Implementations

impl<T: PacketTrait> PoolObjectTrait for PacketsPool<T>

type InitData = (usize, <T as PoolObjectTrait>::InitData, Arc<MemoryTrackerManager>)

fn allocate_new((cap, init_data, mem_tracker): &Self::InitData) -> Self

fn reset(&mut self)