Struct timely_communication::allocator::thread::Thread

pub struct Thread { /* private fields */ }

An allocator for intra-thread communication.

Implementations

impl Thread

pub fn new() -> Self

Allocates a new thread-local channel allocator.

pub fn new_from<T: 'static>( identifier: usize, events: Rc<RefCell<Vec<usize>>> ) -> (ThreadPusher<Message<T>>, ThreadPuller<Message<T>>)

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

Trait Implementations

impl Allocate for Thread

fn index(&self) -> usize

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

fn peers(&self) -> usize

The number of workers in the communication group.

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

Constructs several send endpoints and one receive endpoint.

fn events(&self) -> &Rc<RefCell<Vec<usize>>>

A shared queue of communication events with channel identifier.

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

Awaits communication events.

fn receive(&mut self)

Ensure that received messages are surfaced in each channel.

fn release(&mut self)

Signal the completion of a batch of reads from channels.

fn pipeline<T: 'static>( &mut self, identifier: usize ) -> (ThreadPusher<Message<T>>, ThreadPuller<Message<T>>)

Constructs a pipeline channel from the worker to itself.