lawkit_python::common::parallel

Function parallel_reduce

Source 
pub fn parallel_reduce<T, U, F, R>(
    data: &[T],
    config: &ParallelConfig,
    map_func: F,
    reduce_func: R,
    initial: U,
) -> Result<ParallelResult<U>, BenfError>
where
    T: Clone + Send + Sync + 'static,
    U: Clone + Send + Sync + 'static,
    F: Fn(&T) -> U + Send + Sync + Copy + 'static,
    R: Fn(U, U) -> U + Send + Sync + 'static,
Expand description

並列リダクション処理