pub fn create_output_channel(
shuffle: &ExchangeInfo,
output_channel_size: usize,
) -> Result<(ChanSenderImpl, Vec<ChanReceiverImpl>)>
Expand description
Output-channel is a synchronous, bounded single-producer-multiple-consumer queue.
The producer is the local task executor, the consumer is
ExchangeService
.
The implementation depends on the shuffling strategy.