poly/reduce.h

Go to the documentation of this file.

#ifndef GRPPI_POLY_REDUCE_H
#define GRPPI_POLY_REDUCE_H

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

namespace grppi {

template <typename InputIt, typename Identity, typename Combiner>
auto reduce_multi_impl(polymorphic_execution & ex, 
                       InputIt first, InputIt last, 
                       Identity identity,
                       Combiner &&combine_op) -> decltype(combine_op(*first,*first))
{
  return {};
}



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



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

template <typename InputIt, typename Identity, typename Combiner>
auto reduce(polymorphic_execution & e, 
            InputIt first, InputIt last, 
            Identity identity, 
            Combiner &&combine_op)
{
  return reduce_multi_impl<
    sequential_execution,
    parallel_execution_native,
    parallel_execution_omp,
    parallel_execution_tbb
  >(e, first, last, identity, std::forward<Combiner>(combine_op));
}

} // end namespace grppi

#endif