poly/mapreduce.h

Go to the documentation of this file.

#ifndef GRPPI_POLY_MAPREDUCE_H
#define GRPPI_POLY_MAPREDUCE_H

#include "polymorphic_execution.h"
#include "../common/support.h"

namespace grppi {

template <typename InputIt, typename Transformer, typename Identity, typename Combiner>
Identity map_reduce_multi_impl(polymorphic_execution & e, InputIt first, InputIt last, 
  Identity identity, Transformer && transform_op, Combiner && combine_op) 
{
  return {};
}

template <typename E, typename ... O,
          typename InputIt, typename Transformer, typename Identity, typename Combiner,
          internal::requires_execution_not_supported<E> = 0>
Identity map_reduce_multi_impl(polymorphic_execution & e, InputIt first, InputIt last, 
  Identity identity, Transformer && transform_op, Combiner && combine_op) 
{
  return map_reduce_multi_impl<O...>(e, first, last, identity, std::forward<Transformer>(transform_op), 
    std::forward<Combiner>(combine_op));
}

template <typename E, typename ... O,
          typename InputIt, typename Transformer, typename Identity, typename Combiner,
          internal::requires_execution_supported<E> = 0>
Identity map_reduce_multi_impl(polymorphic_execution & e, InputIt first, InputIt last, Identity identity,
  Transformer && transform_op, Combiner && combine_op) 
{
  if (typeid(E) == e.type()) {
    return map_reduce(*e.execution_ptr<E>(), 
        first, last, identity, std::forward<Transformer>(transform_op), 
        std::forward<Combiner>(combine_op));
  }
  else {
    return map_reduce_multi_impl<O...>(e, first, last, identity, std::forward<Transformer>(transform_op), 
        std::forward<Combiner>(combine_op));
  }
}

template <typename InputIt, typename Transformer, typename Result, 
          typename Combiner>
Result map_reduce(polymorphic_execution & ex, 
                  InputIt first, InputIt last, Result identity,
                  Transformer && transform_op, 
                  Combiner && combine_op) 
{
  return map_reduce_multi_impl<
    sequential_execution,
    parallel_execution_native,
    parallel_execution_omp,
    parallel_execution_tbb
  >(ex, first, last, identity, std::forward<Transformer>(transform_op), 
        std::forward<Combiner>(combine_op));
}

} // end namespace grppi

#endif