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