Enum Allocator 

pub enum Allocator {
    Thread(Thread),
    Process(Process),
    Tcp(TcpAllocator),
}

Enumerates known implementors of Allocate. Passes trait method calls on to members.

Variants

Thread(Thread)

Intra-thread allocator.

Process(Process)

Inter-thread, intra-process allocator (in either of two flavors, see Process).

Tcp(TcpAllocator)

Inter-process allocator (TCP-based, with a Process as its intra-process inner).

Implementations

impl Allocator

pub fn index(&self) -> usize

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

pub fn peers(&self) -> usize

The number of workers.

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

where T: Exchangeable,

Constructs several send endpoints and one receive endpoint.

pub fn broadcast<T>( &mut self, identifier: usize, ) -> (Box<dyn Push<T>>, Box<dyn Pull<T>>)

where T: Exchangeable + Clone,

Constructs several send endpoints and one receive endpoint.

pub fn receive(&mut self)

Perform work before scheduling operators.

pub fn release(&mut self)

Perform work after scheduling operators.

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

Provides access to the shared event queue.

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

Awaits communication events.

pub fn pipeline<T>( &mut self, identifier: usize, ) -> (Pusher<T, Pusher<T>>, Puller<T, Puller<T>>)

where T: 'static,

Constructs a pipeline channel from the worker to itself.

By default, this method uses the thread-local channel constructor based on a shared VecDeque which updates the event queue.