Struct timely_communication::allocator::thread::Thread

pub struct Thread;

Methods

impl Thread

pub fn new<T: 'static>() -> (Pusher<T>, Puller<T>)

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.

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

Constructs several send endpoints and one receive endpoint.