Struct catalyst_entities::FragBase

pub struct FragBase<T> { /* private fields */ }

Structure is able to create FragMaps that can be distributed to other threads. Its a synchronization point for all threads but does not require any synchronization primitives, rather it is designed for channel based communication.

Implementations

impl<T> FragBase<T>

pub fn new(thread_count: u8) -> Self

Creates new FragBase with thread_count threads.

pub fn expand(&mut self, thread_count: u8)

Extend FragBase to thread_count threads.

pub fn split(&mut self) -> impl Iterator<Item = FragMap<T>> + '_

Returns iterator of fragmaps, distributing access to threads.

Panics

Panics FragMaps belonging to this FragBase still exists. (eg. Subsequent call to split while keeping FragMaps alive)

pub fn is_unique(&mut self) -> bool

Returns whether all FragMaps belonging to this FragBase are dropped.

Trait Implementations

impl<T> Archive for FragBase<T>where Box<[FragVec<T>]>: Archive,

type Archived = ArchivedFragBase<T>

The archived representation of this type.

type Resolver = FragBaseResolver<T>

The resolver for this type. It must contain all the additional information from serializing needed to make the archived type from the normal type.

unsafe fn resolve( &self, pos: usize, resolver: Self::Resolver, out: *mut Self::Archived )

Creates the archived version of this value at the given position and writes it to the given output.

impl<__D: Fallible + ?Sized, T> Deserialize<FragBase<T>, __D> for Archived<FragBase<T>>where Box<[FragVec<T>]>: Archive, Archived<Box<[FragVec<T>]>>: Deserialize<Box<[FragVec<T>]>, __D>,

fn deserialize(&self, deserializer: &mut __D) -> Result<FragBase<T>, __D::Error>

Deserializes using the given deserializer

impl<T: Relocated + 'static> DynFragMap for FragBase<T>

fn mark(&self, addr: FragSliceAddr, marker: &mut FragRelocMarker)

fn remap(&mut self, ctx: &FragMarks)

fn filter(&mut self, marks: &mut FragMarkShard)

fn is_unique(&mut self) -> bool

fn item_id(&self) -> TypeId

impl<T: NoInteriorMutability> Index<FragRef<T>> for FragBase<T>

type Output = T

The returned type after indexing.

fn index(&self, index: FragRef<T>) -> &Self::Output

Performs the indexing (container[index]) operation.

impl<T: NoInteriorMutability> Index<FragSlice<T>> for FragBase<T>

type Output = [T]

The returned type after indexing.

fn index(&self, index: FragSlice<T>) -> &Self::Output

Performs the indexing (container[index]) operation.

impl<__S: Fallible + ?Sized, T> Serialize<__S> for FragBase<T>where Box<[FragVec<T>]>: Serialize<__S>,

fn serialize(&self, serializer: &mut __S) -> Result<Self::Resolver, __S::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.