Struct SharedMemoryObject

Source
pub struct SharedMemoryObject<T> { /* private fields */ }
Expand description

An object that can be shared between processes.

After spawning child process (using fork(), clone(), etc.) updates to this object will be seen by both processes. This is achieved by allocating memory using mmap with MAP_SHARED flag.

For more details see man page.

§Example

let mut shared = SharedMemoryObject::new(123)?;

let pid = unsafe { fork() };
assert!(pid >= 0);

if pid == 0 {
    assert_eq!(*shared.get(), 123);
    *shared.get_mut() = 456;
    sleep(Duration::from_millis(40));
    assert_eq!(*shared.get(), 789);
} else {
    sleep(Duration::from_millis(20));
    assert_eq!(*shared.get(), 456);
    *shared.get_mut() = 789;
}

Implementations§

Source§

impl<T: Sync + Send> SharedMemoryObject<T>

Source

pub fn new(obj: T) -> Result<Self>

Allocates shared memory and moves obj there.

§Errors

If allocation fails returns error from last_os_error.

Source

pub fn get(&self) -> &T

Returns reference to underlying object.

§Safety

See get_mut.

Source

pub fn get_mut(&mut self) -> &mut T

Returns mutable reference to underlying object.

§Safety

This function (and get) is always safe to call, but access to data under returned reference must be somehow synchronized with another processes to avoid data race.

Trait Implementations§

Source§

impl<T> Drop for SharedMemoryObject<T>

Source§

fn drop(&mut self)

Executes the destructor for this type. 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> 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.