Enum timely_communication::allocator::generic::Generic
source · pub enum Generic {
Thread(Thread),
Process(Process),
ProcessBinary(ProcessAllocator),
ZeroCopy(TcpAllocator<Process>),
}
Expand description
Enumerates known implementors of Allocate
.
Passes trait method calls on to members.
Variants§
Thread(Thread)
Intra-thread allocator.
Process(Process)
Inter-thread, intra-process allocator.
ProcessBinary(ProcessAllocator)
Inter-thread, intra-process serializing allocator.
ZeroCopy(TcpAllocator<Process>)
Inter-process allocator.
Implementations§
Trait Implementations§
source§impl Allocate for Generic
impl Allocate for Generic
source§fn allocate<T: Exchangeable>(
&mut self,
identifier: usize,
) -> (Vec<Box<dyn Push<T>>>, Box<dyn Pull<T>>)
fn allocate<T: Exchangeable>( &mut self, identifier: usize, ) -> (Vec<Box<dyn Push<T>>>, Box<dyn Pull<T>>)
Constructs several send endpoints and one receive endpoint.
source§fn events(&self) -> &Rc<RefCell<Vec<usize>>>
fn events(&self) -> &Rc<RefCell<Vec<usize>>>
A shared queue of communication events with channel identifier. Read more
source§fn pipeline<T: 'static>(
&mut self,
identifier: usize,
) -> (ThreadPusher<T>, ThreadPuller<T>)
fn pipeline<T: 'static>( &mut self, identifier: usize, ) -> (ThreadPusher<T>, ThreadPuller<T>)
Constructs a pipeline channel from the worker to itself. Read more
Auto Trait Implementations§
impl Freeze for Generic
impl !RefUnwindSafe for Generic
impl !Send for Generic
impl !Sync for Generic
impl Unpin for Generic
impl !UnwindSafe for Generic
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more