Struct timely::communication::allocator::Thread

pub struct Thread { /* fields omitted */ }

An allocator for intra-thread communication.

Implementations

impl Thread

pub fn new() -> Thread

Allocates a new thread-local channel allocator.

pub fn new_from<T>(
    identifier: usize,
    events: Rc<RefCell<VecDeque<(usize, Event)>>>
) -> (Pusher<Message<T>, Pusher<Message<T>>>, Puller<Message<T>, Puller<Message<T>>>) where
    T: 'static, 

Creates a new thread-local channel from an identifier and shared counts.

Trait Implementations

impl Allocate for Thread

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: 'static, 

Constructs several send endpoints and one receive endpoint.

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 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 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.