Struct crossbeam::utils::CachePadded

pub struct CachePadded<T> { /* fields omitted */ }

Pads and aligns a value to the length of a cache line.

In concurrent programming, sometimes it is desirable to make sure commonly accessed pieces of data are not placed into the same cache line. Updating an atomic value invalides the whole cache line it belongs to, which makes the next access to the same cache line slower for other CPU cores. Use CachePadded to ensure updating one piece of data doesn't invalidate other cached data.

Cache lines are assumed to be 64 bytes on all architectures.

Size and alignment

The size of CachePadded<T> is the smallest multiple of 64 bytes large enough to accommodate a value of type T.

The alignment of CachePadded<T> is the maximum of 64 bytes and the alignment of T.

Examples

Alignment and padding:

use crossbeam_utils::CachePadded;

let array = [CachePadded::new(1i32), CachePadded::new(2i32)];
let addr1 = &*array[0] as *const i32 as usize;
let addr2 = &*array[1] as *const i32 as usize;

assert_eq!(addr2 - addr1, 64);
assert_eq!(addr1 % 64, 0);
assert_eq!(addr2 % 64, 0);

When building a concurrent queue with a head and a tail index, it is wise to place them in different cache lines so that concurrent threads pushing and popping elements don't invalidate each other's cache lines:

use crossbeam_utils::CachePadded;
use std::sync::atomic::AtomicUsize;

struct Queue<T> {
    head: CachePadded<AtomicUsize>,
    tail: CachePadded<AtomicUsize>,
    buffer: *mut T,
}

Methods

impl<T> CachePadded<T>

pub fn new(t: T) -> CachePadded<T>

Pads and aligns a value to the length of a cache line.

Examples

use crossbeam_utils::CachePadded;

let padded_value = CachePadded::new(1);

pub fn into_inner(self) -> T

Returns the value value.

Examples

use crossbeam_utils::CachePadded;

let padded_value = CachePadded::new(7);
let value = padded_value.into_inner();
assert_eq!(value, 7);

Trait Implementations

impl<T> Copy for CachePadded<T> where
    T: Copy, 

impl<T> Debug for CachePadded<T> where
    T: Debug, 

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

Formats the value using the given formatter.

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

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Eq for CachePadded<T> where
    T: Eq, 

impl<T> Sync for CachePadded<T> where
    T: Sync, 

impl<T> Hash for CachePadded<T> where
    T: Hash, 

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

Feeds this value into the given [Hasher].

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

Feeds a slice of this type into the given [Hasher].

impl<T> From<T> for CachePadded<T>

fn from(t: T) -> CachePadded<T>

Performs the conversion.

impl<T> Deref for CachePadded<T>

type Target = T

The resulting type after dereferencing.

Important traits for &'_ mut W

impl<'_, W> Write for &'_ mut W where
    W: Write + ?Sized, impl<'_, R> Read for &'_ mut R where
    R: Read + ?Sized, impl<'_, I> Iterator for &'_ mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;impl<'_, F> Future for &'_ mut F where
    F: Unpin + Future + ?Sized,  type Output = <F as Future>::Output;

fn deref(&self) -> &T

Dereferences the value.

impl<T> PartialEq<CachePadded<T>> for CachePadded<T> where
    T: PartialEq<T>, 

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

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &CachePadded<T>) -> bool

This method tests for !=.

impl<T> Default for CachePadded<T> where
    T: Default, 

fn default() -> CachePadded<T>

Returns the "default value" for a type.

impl<T> DerefMut for CachePadded<T>

Important traits for &'_ mut W

impl<'_, W> Write for &'_ mut W where
    W: Write + ?Sized, impl<'_, R> Read for &'_ mut R where
    R: Read + ?Sized, impl<'_, I> Iterator for &'_ mut I where
    I: Iterator + ?Sized,  type Item = <I as Iterator>::Item;impl<'_, F> Future for &'_ mut F where
    F: Unpin + Future + ?Sized,  type Output = <F as Future>::Output;

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

Mutably dereferences the value.

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