Skip to main content

spawn_pipeline

atomr_accel_cuda::pipeline

Function spawn_pipeline 

Source 
pub fn spawn_pipeline<I, O>(
    executor: PipelineExecutorN,
    streams: Vec<Arc<CudaStream>>,
    completion: Arc<dyn CompletionStrategy>,
    head_capacity: usize,
    tail_capacity: usize,
) -> (PipelineSink<I>, PipelineSource<O>)
where
    I: Send + 'static,
    O: Send + 'static,
Expand description

Spawn a backpressured async pipeline driver around an executor. Returns (PipelineSink<I>, PipelineSource<O>). The driver runs on the ambient tokio runtime.