Struct timely_communication::allocator::process::Process

pub struct Process { /* fields omitted */ }

Methods

impl Process

pub fn inner<'a>(&'a mut self) -> &'a mut Thread

pub fn new_vector(count: usize) -> Vec<Process>

Trait Implementations

impl Allocate for Process

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: Any + Send + 'static>(
    &mut self
) -> (Vec<Box<Push<T>>>, Box<Pull<T>>, Option<usize>)

Constructs several send endpoints and one receive endpoint.