RawOpaquePool

Struct RawOpaquePool 

Source
pub struct RawOpaquePool { /* private fields */ }
Expand description

A pool of objects with uniform memory layout.

Stores objects of any type that match a Layout defined at pool creation time. All values in the pool remain pinned for their entire lifetime.

The pool automatically expands its capacity when needed.

§Thread safety

The pool is single-threaded, though if all the objects inserted are Send then the owner of the pool is allowed to treat the pool itself as Send (but must do so via a wrapper type that implements Send using unsafe code).

§Example

use infinity_pool::RawOpaquePool;

fn work_with_displayable<T: std::fmt::Display + 'static + Unpin>(value: T) {
    let mut pool = RawOpaquePool::with_layout_of::<T>();

    // Insert an object into the pool
    let handle = pool.insert(value);

    // Access the object through the handle
    let stored_value = unsafe { handle.ptr().as_ref() };
    println!("Stored: {}", stored_value);

    // Explicitly remove the object from the pool
    pool.remove_mut(handle);
}

work_with_displayable("Hello, world!");
work_with_displayable(42);

Implementations§

Source§

impl RawOpaquePool

Source

pub fn builder() -> RawOpaquePoolBuilder

Starts configuring and creating a new instance of the pool.

Source

pub fn with_layout(object_layout: Layout) -> Self

Creates a new instance of the pool with the specified layout.

Shorthand for a builder that keeps all other options at their default values.

§Panics

Panics if the layout is zero-sized.

Source

pub fn with_layout_of<T: Sized>() -> Self

Creates a new instance of the pool with the layout of T.

Shorthand for a builder that keeps all other options at their default values.

§Panics

Panics if T is a zero-sized type.

Source

pub fn object_layout(&self) -> Layout

The layout of objects stored in this pool.

All inserted objects must match this layout.

Source

pub fn len(&self) -> usize

The number of objects currently in the pool.

Source

pub fn capacity(&self) -> usize

The total capacity of the pool.

This is the maximum number of objects (including current contents) that the pool can contain without capacity extension. The pool will automatically extend its capacity if more than this many objects are inserted.

Source

pub fn is_empty(&self) -> bool

Whether the pool contains zero objects.

Source

pub fn reserve(&mut self, additional: usize)

Ensures that the pool has capacity for at least additional more objects.

§Panics

Panics if the new capacity would exceed the size of virtual memory (usize::MAX).

Source

pub fn shrink_to_fit(&mut self)

Drops unused pool capacity to reduce memory usage.

There is no guarantee that any unused capacity can be dropped. The exact outcome depends on the specific pool structure and which objects remain in the pool.

Source

pub fn insert<T>(&mut self, value: T) -> RawPooledMut<T>

Inserts an object into the pool and returns a handle to it.

§Panics

Panics if the layout of T does not match the object layout of the pool.

§Example
use std::alloc::Layout;

use infinity_pool::RawOpaquePool;

let mut pool = RawOpaquePool::with_layout(Layout::new::<String>());

// Insert an object into the pool
let mut handle = pool.insert("Hello".to_string());

// Mutate the object via the unique handle
// SAFETY: The handle is valid and points to a properly initialized String
unsafe {
    handle.as_mut().push_str(", Raw Opaque World!");
    assert_eq!(handle.as_ref(), "Hello, Raw Opaque World!");
}

// Transform the unique handle into a shared handle
let shared_handle = handle.into_shared();

// After transformation, you can only immutably dereference the object
// SAFETY: The shared handle is valid and points to a properly initialized String
unsafe {
    assert_eq!(shared_handle.as_ref(), "Hello, Raw Opaque World!");
    // shared_handle.as_mut(); // This would not compile
}

// Explicitly remove the object from the pool
// SAFETY: The handle belongs to this pool and references a valid object
unsafe {
    pool.remove(shared_handle);
}
assert_eq!(pool.len(), 0);
Source

pub unsafe fn insert_unchecked<T>(&mut self, value: T) -> RawPooledMut<T>

Inserts an object into the pool and returns a handle to it.

§Safety

The caller must ensure that the layout of T matches the pool’s object layout.

Source

pub unsafe fn insert_with<T, F>(&mut self, f: F) -> RawPooledMut<T>
where F: FnOnce(&mut MaybeUninit<T>),

Inserts an object into the pool via closure and returns a handle to it.

This method allows the caller to partially initialize the object, skipping any MaybeUninit fields that are intentionally not initialized at insertion time. This can make insertion of objects containing MaybeUninit fields faster, although requires unsafe code to implement.

This method is NOT faster than insert() for fully initialized objects. Prefer insert() for a better safety posture if you do not intend to skip initialization of any MaybeUninit fields.

§Example
use std::mem::MaybeUninit;

use infinity_pool::RawOpaquePool;

struct DataBuffer {
    id: u32,
    data: MaybeUninit<[u8; 1024]>, // Large buffer to skip initializing
}

let mut pool = RawOpaquePool::with_layout_of::<DataBuffer>();

// Initialize only the id, leaving data uninitialized for performance
let handle = unsafe {
    pool.insert_with(|uninit: &mut MaybeUninit<DataBuffer>| {
        let ptr = uninit.as_mut_ptr();
        // SAFETY: Writing to the id field within allocated space
        unsafe {
            std::ptr::addr_of_mut!((*ptr).id).write(42);
            // data field is intentionally left uninitialized
        }
    })
};

// ID is accessible, data remains uninitialized
let id = unsafe { std::ptr::addr_of!(handle.ptr().as_ref().id).read() };
assert_eq!(id, 42);
§Panics

Panics if the layout of T does not match the object layout of the pool.

§Safety

The closure must correctly initialize the object. All fields that are not MaybeUninit must be initialized when the closure returns.

Source

pub unsafe fn insert_with_unchecked<T, F>(&mut self, f: F) -> RawPooledMut<T>
where F: FnOnce(&mut MaybeUninit<T>),

Inserts an object into the pool via closure and returns a handle to it.

This method allows the caller to partially initialize the object, skipping any MaybeUninit fields that are intentionally not initialized at insertion time. This can make insertion of objects containing MaybeUninit fields faster, although requires unsafe code to implement.

This method is NOT faster than insert() for fully initialized objects. Prefer insert() for a better safety posture if you do not intend to skip initialization of any MaybeUninit fields.

§Example
use std::mem::MaybeUninit;

use infinity_pool::RawOpaquePool;

struct DataBuffer {
    id: u32,
    data: MaybeUninit<[u8; 1024]>, // Large buffer to skip initializing
}

let mut pool = RawOpaquePool::with_layout_of::<DataBuffer>();

// Initialize only the id, leaving data uninitialized for performance
let handle = unsafe {
    pool.insert_with_unchecked(|uninit: &mut MaybeUninit<DataBuffer>| {
        let ptr = uninit.as_mut_ptr();
        // SAFETY: Writing to the id field within allocated space
        unsafe {
            std::ptr::addr_of_mut!((*ptr).id).write(42);
            // data field is intentionally left uninitialized
        }
    })
};

// ID is accessible, data remains uninitialized
let id = unsafe { std::ptr::addr_of!(handle.ptr().as_ref().id).read() };
assert_eq!(id, 42);
§Safety

The caller must ensure that the layout of T matches the pool’s object layout. The closure must correctly initialize the object. All fields that are not MaybeUninit must be initialized when the closure returns.

Source

pub fn remove_mut<T: ?Sized>(&mut self, handle: RawPooledMut<T>)

Removes an object from the pool, dropping it.

§Panics

Panics if the handle does not reference an object in this pool.

Source

pub unsafe fn remove<T: ?Sized>(&mut self, handle: RawPooled<T>)

Removes an object from the pool, dropping it.

§Panics

Panics if the handle does not reference an object in this pool.

§Safety

The caller must ensure that the handle belongs to this pool and that the object it references has not already been removed from the pool.

Source

pub fn remove_mut_unpin<T: Unpin>(&mut self, handle: RawPooledMut<T>) -> T

Removes an object from the pool and returns it.

§Panics

Panics if the handle does not reference an object in this pool.

Panics if the handle has been type-erased (T is ()).

Source

pub unsafe fn remove_unpin<T: Unpin>(&mut self, handle: RawPooled<T>) -> T

Removes an object from the pool and returns it.

§Panics

Panics if the handle does not reference an existing object in this pool.

Panics if the handle has been type-erased (T is ()).

§Safety

The caller must ensure that the handle belongs to this pool and that the object it references has not already been removed from the pool.

Source

pub fn iter(&self) -> RawOpaquePoolIterator<'_>

Returns an iterator over all objects in the pool.

The iterator yields untyped pointers (NonNull<()>) to the objects stored in the pool. It is the caller’s responsibility to cast these pointers to the appropriate type.

Trait Implementations§

Source§

impl Debug for RawOpaquePool

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<'p> IntoIterator for &'p RawOpaquePool

Source§

type Item = NonNull<()>

The type of the elements being iterated over.
Source§

type IntoIter = RawOpaquePoolIterator<'p>

Which kind of iterator are we turning this into?
Source§

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> Conv for T

Source§

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more
Source§

impl<T> FmtForward for T

Source§

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.
Source§

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.
Source§

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.
Source§

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.
Source§

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.
Source§

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.
Source§

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.
Source§

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.
Source§

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Pipe for T
where T: ?Sized,

Source§

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more
Source§

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more
Source§

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more
Source§

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.
Source§

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.
Source§

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.
Source§

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.
Source§

impl<T> Tap for T

Source§

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more
Source§

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more
Source§

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more
Source§

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more
Source§

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more
Source§

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more
Source§

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more
Source§

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more
Source§

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.
Source§

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.
Source§

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.
Source§

impl<T> TryConv for T

Source§

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.