Skip to main content

GPooled

Struct GPooled 

Source
pub struct GPooled<T: Poolable> { /* private fields */ }
Expand description

A wrapper for globally pooled objects with cross-thread pool affinity.

GPooled<T> ensures objects always return to their origin pool, regardless of which thread drops them. This is essential for producer-consumer patterns where one thread creates objects and other threads consume them.

§When to Use

Use GPooled when:

  • One thread primarily creates objects, other threads consume them
  • You need objects to return to a specific pool
  • You have a producer-consumer pattern across threads

Otherwise, prefer LPooled for better performance.

§Example

use poolshark::global::{Pool, GPooled};
use std::sync::LazyLock;

// Shared pool for cross-thread usage
static MESSAGES: LazyLock<Pool<String>> = LazyLock::new(|| Pool::new(1024, 4096));

fn producer() -> GPooled<String> {
    let mut msg = MESSAGES.take();
    msg.push_str("Hello from producer");
    msg  // Can be sent to consumer thread
}

fn consumer(msg: GPooled<String>) {
    println!("{}", msg);
    // Dropped here, returns to MESSAGES pool (not consumer's thread-local pool)
}

§Behavior

  • Pool affinity: Always returns to the pool it was created from
  • Thread-safe: Can be sent between threads
  • Overhead: One word (8 bytes on 64-bit) to store pool pointer
  • Lock-free: Uses crossbeam lock-free queues

Implementations§

Source§

impl<T: IsoPoolable> GPooled<T>

Source

pub fn take() -> Self

Source

pub fn take_sz(max: usize, max_elements: usize) -> Self

Source§

impl<T: Poolable> GPooled<T>

Source

pub fn orphan(t: T) -> Self

Creates a GPooled that isn’t connected to any pool.

Useful for branches where you know a given Pooled will always be empty.

Source

pub fn assign(&mut self, pool: &Pool<T>)

Assign the GPooled to the specified pool.

When dropped, it will be placed in pool instead of the pool it was originally allocated from. If an orphan is assigned a pool it will no longer be orphaned.

Source

pub fn detach(self) -> T

Detach the object from the pool, returning the inner value.

The detached object will not be returned to any pool when dropped.

Trait Implementations§

Source§

impl<T: Poolable> AsRef<T> for GPooled<T>

Source§

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.
Source§

impl<T: Poolable> Borrow<T> for GPooled<T>

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl Borrow<str> for GPooled<String>

Source§

fn borrow(&self) -> &str

Immutably borrows from an owned value. Read more
Source§

impl<T: Clone + Poolable> Clone for GPooled<T>

Source§

fn clone(&self) -> GPooled<T>

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl<T: Poolable + Debug> Debug for GPooled<T>

Source§

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

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

impl<T: IsoPoolable> Default for GPooled<T>

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl<T: Poolable> Deref for GPooled<T>

Source§

type Target = T

The resulting type after dereferencing.
Source§

fn deref(&self) -> &T

Dereferences the value.
Source§

impl<T: Poolable> DerefMut for GPooled<T>

Source§

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

Mutably dereferences the value.
Source§

impl<'de, T: Poolable + DeserializeOwned + 'static> Deserialize<'de> for GPooled<T>

Available on crate feature serde only.
Source§

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
Source§

impl<T: Poolable + Display> Display for GPooled<T>

Source§

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

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

impl<T: Poolable> Drop for GPooled<T>

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more
Source§

impl<T: IsoPoolable + Extend<E>, E> Extend<E> for GPooled<T>

Source§

fn extend<I: IntoIterator<Item = E>>(&mut self, iter: I)

Extends a collection with the contents of an iterator. Read more
Source§

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)
Extends a collection with exactly one element.
Source§

fn extend_reserve(&mut self, additional: usize)

🔬This is a nightly-only experimental API. (extend_one)
Reserves capacity in a collection for the given number of additional elements. Read more
Source§

impl<T: Poolable + Hash> Hash for GPooled<T>

Source§

fn hash<H>(&self, state: &mut H)
where H: Hasher,

Feeds this value into the given Hasher. Read more
1.3.0 · Source§

fn hash_slice<H>(data: &[Self], state: &mut H)
where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher. Read more
Source§

impl<T: Poolable + Ord> Ord for GPooled<T>

Source§

fn cmp(&self, other: &GPooled<T>) -> Ordering

This method returns an Ordering between self and other. Read more
1.21.0 · Source§

fn max(self, other: Self) -> Self
where Self: Sized,

Compares and returns the maximum of two values. Read more
1.21.0 · Source§

fn min(self, other: Self) -> Self
where Self: Sized,

Compares and returns the minimum of two values. Read more
1.50.0 · Source§

fn clamp(self, min: Self, max: Self) -> Self
where Self: Sized,

Restrict a value to a certain interval. Read more
Source§

impl<T: Poolable + PartialEq> PartialEq for GPooled<T>

Source§

fn eq(&self, other: &GPooled<T>) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl<T: Poolable + PartialOrd> PartialOrd for GPooled<T>

Source§

fn partial_cmp(&self, other: &GPooled<T>) -> Option<Ordering>

This method returns an ordering between self and other values if one exists. Read more
1.0.0 · Source§

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator. Read more
1.0.0 · Source§

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator. Read more
1.0.0 · Source§

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator. Read more
1.0.0 · Source§

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator. Read more
Source§

impl<T: Poolable> RawPoolable for GPooled<T>

Source§

fn empty(pool: WeakPool<Self>) -> Self

allocate a new empty object and set it’s pool pointer to pool
Source§

fn reset(&mut self)

empty the collection and reset it to its default state so it can be put back in the pool
Source§

fn capacity(&self) -> usize

return the capacity of the collection
Source§

fn really_drop(self)

Actually drop the inner object, don’t put it back in the pool, make sure you do not call both this method and the drop implementation that puts the object back in the pool!
Source§

impl<T: Poolable + Serialize> Serialize for GPooled<T>

Available on crate feature serde only.
Source§

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

Serialize this value into the given Serde serializer. Read more
Source§

impl<T: Poolable + Eq> Eq for GPooled<T>

Auto Trait Implementations§

§

impl<T> Freeze for GPooled<T>
where T: Freeze,

§

impl<T> RefUnwindSafe for GPooled<T>
where T: RefUnwindSafe,

§

impl<T> Send for GPooled<T>
where T: Send,

§

impl<T> Sync for GPooled<T>
where T: Sync + Send,

§

impl<T> Unpin for GPooled<T>
where T: Unpin,

§

impl<T> UnwindSafe for GPooled<T>
where T: UnwindSafe,

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> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<Q, K> Comparable<K> for Q
where Q: Ord + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn compare(&self, key: &K) -> Ordering

Compare self to key and return their ordering.
Source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
Source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
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<P, T> Receiver for P
where P: Deref<Target = T> + ?Sized, T: ?Sized,

Source§

type Target = T

🔬This is a nightly-only experimental API. (arbitrary_self_types)
The target type on which the method may be called.
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T> ToString for T
where T: Display + ?Sized,

Source§

fn to_string(&self) -> String

Converts the given value to a String. 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.
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,