Struct timely::communication::allocator::zero_copy::allocator_process::ProcessAllocator

pub struct ProcessAllocator { /* fields omitted */ }

A serializing allocator for inter-thread intra-process communication.

Trait Implementations

impl Allocate for ProcessAllocator

pub fn index(&self) -> usize

The index of the worker out of (0..self.peers()).

pub fn peers(&self) -> usize

The number of workers in the communication group.

pub fn allocate<T>(
    &mut self,
    identifier: usize
) -> (Vec<Box<dyn Push<Message<T>> + 'static, Global>, Global>, Box<dyn Pull<Message<T>> + 'static, Global>) where
    T: Data, 

Constructs several send endpoints and one receive endpoint.

pub fn receive(&mut self)

Ensure that received messages are surfaced in each channel.

pub fn release(&mut self)

Signal the completion of a batch of reads from channels.

pub fn events(&self) -> &Rc<RefCell<VecDeque<(usize, Event)>>>

A shared queue of communication events with channel identifier.

pub fn await_events(&self, duration: Option<Duration>)

Awaits communication events.

pub fn pipeline<T>(
    &mut self,
    identifier: usize
) -> (Pusher<Message<T>, Pusher<Message<T>>>, Puller<Message<T>, Puller<Message<T>>>) where
    T: 'static, 

Constructs a pipeline channel from the worker to itself.