Swapper

swapper

Struct Swapper 

Source 
pub struct Swapper<T> {
    pub(crate) contents: Arc<AtomicPtr<T>>,
    pub(crate) wait: Receiver<()>,
    pub(crate) notify: Sender<()>,
}
Expand description

A concurrency control for swapping ownership between threads.

Fields§

§contents: Arc<AtomicPtr<T>>§wait: Receiver<()>§notify: Sender<()>

Implementations§

Source§

impl<T: Send> Swapper<T>

Source

pub fn swap(&self, our_ref: &mut T) -> Result<(), SwapError>

Swap data.

If the other half of the swap pair is blocked waiting to swap, then it swaps ownership of the data, then unblocks the other thread. Otherwise it blocks waiting to swap.

Trait Implementations§

Source§

impl<T: Send> Send for Swapper<T>

Auto Trait Implementations§

§

impl<T> Freeze for Swapper<T>

§

impl<T> RefUnwindSafe for Swapper<T>

§

impl<T> !Sync for Swapper<T>

§

impl<T> Unpin for Swapper<T>

§

impl<T> UnwindSafe for Swapper<T>

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> 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, 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.