Function timely::communication::allocator::zero_copy::allocator::new_vector

source ·
pub fn new_vector<A>(
    allocators: Vec<A>,
    my_process: usize,
    processes: usize
) -> (Vec<TcpBuilder<A>>, Vec<Vec<Sender<MergeQueue>>>, Vec<Vec<Receiver<MergeQueue>>>)
where A: AllocateBuilder,
Expand description

Creates a vector of builders, sharing appropriate state.

threads is the number of workers in a single process, processes is the total number of processes. The returned tuple contains

  AllocateBuilder for local threads,
  info to spawn egress comm threads,
  info to spawn ingress comm thresds,