Trait timely_communication::allocator::Allocate

pub trait Allocate {
    fn index(&self) -> usize;
    fn peers(&self) -> usize;
    fn allocate<T: Data>(
        &mut self
    ) -> (Vec<Box<Push<T>>>, Box<Pull<T>>, Option<usize>);
}

Required Methods

fn index(&self) -> usize

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

fn peers(&self) -> usize

The number of workers.

fn allocate<T: Data>(
    &mut self
) -> (Vec<Box<Push<T>>>, Box<Pull<T>>, Option<usize>)

Constructs several send endpoints and one receive endpoint.

Implementors

• impl Allocate for Thread

• impl Allocate for Process

• impl Allocate for Binary

• impl Allocate for Generic