seq/mapreduce.h

Go to the documentation of this file.

#ifndef GRPPI_SEQ_MAPREDUCE_H
#define GRPPI_SEQ_MAPREDUCE_H

#include "sequential_execution.h"

namespace grppi {

template <typename InputIt, typename Result, typename Transformer, 
          typename Combiner>
Result map_reduce(sequential_execution &, 
                  InputIt first, InputIt last, 
                  Result identity, 
                  Transformer &&  transform_op, Combiner && combine_op)
{
  Result out = identity;

  using namespace std;

  while (first!=last) {
    auto x = transform_op(*first);
    out = combine_op(out,x);
    first++;
  }

  return out;
}

}

#endif