Function timely::communication::allocator::zero_copy::allocator::new_vector [−][src]
pub fn new_vector<A>(
allocators: Vec<A, Global>,
my_process: usize,
processes: usize
) -> (Vec<TcpBuilder<A>, Global>, Vec<Vec<Sender<MergeQueue>, Global>, Global>, Vec<Vec<Receiver<MergeQueue>, Global>, Global>) where
A: AllocateBuilder,
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, )