[−][src]Enum timely_communication::allocator::generic::Generic
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.
Methods
impl Generic
[src]
pub fn index(&self) -> usize
[src]
The index of the worker out of (0..self.peers())
.
pub fn peers(&self) -> usize
[src]
The number of workers.
pub fn release(&mut self)
[src]
Perform work after scheduling operators.
Trait Implementations
impl Allocate for Generic
[src]
fn index(&self) -> usize
[src]
fn peers(&self) -> usize
[src]
fn allocate<T: Data>(
&mut self,
identifier: usize
) -> (Vec<Box<dyn Push<Message<T>>>>, Box<dyn Pull<Message<T>>>)
[src]
&mut self,
identifier: usize
) -> (Vec<Box<dyn Push<Message<T>>>>, Box<dyn Pull<Message<T>>>)
fn receive(&mut self)
[src]
fn release(&mut self)
[src]
fn events(&self) -> &Rc<RefCell<VecDeque<(usize, Event)>>>
[src]
fn await_events(&self, _duration: Option<Duration>)
[src]
fn pipeline<T: 'static>(
&mut self,
identifier: usize
) -> (ThreadPusher<Message<T>>, ThreadPuller<Message<T>>)
[src]
&mut self,
identifier: usize
) -> (ThreadPusher<Message<T>>, ThreadPuller<Message<T>>)
Constructs a pipeline channel from the worker to itself. Read more
Auto Trait Implementations
impl !Sync for Generic
impl Unpin for Generic
impl !Send for Generic
impl !RefUnwindSafe for Generic
impl !UnwindSafe for Generic
Blanket Implementations
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> From<T> for T
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,