Function timely_communication::allocator::zero_copy::allocator::new_vector

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

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,
)