Struct timely::communication::allocator::zero_copy::allocator_process::ProcessBuilder

pub struct ProcessBuilder { /* fields omitted */ }

Builds an instance of a ProcessAllocator.

Builders are required because some of the state in a ProcessAllocator cannot be sent between threads (specifically, the Rc<RefCell<_>> local channels). So, we must package up the state shared between threads here, and then provide a method that will instantiate the non-movable members once in the destination thread.

Methods

impl ProcessBuilder

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

Creates a vector of builders, sharing appropriate state.

This method requires access to a byte exchanger, from which it mints channels.

pub fn build(self) -> ProcessAllocator

Builds a ProcessAllocator, instantiating Rc<RefCell<_>> elements.

Trait Implementations

impl AllocateBuilder for ProcessBuilder

type Allocator = ProcessAllocator

The type of allocator to be built.

fn build(self) -> <ProcessBuilder as AllocateBuilder>::Allocator

Builds allocator, consumes self.