MapReduceBase Class

(Utils::Internal::MapReduceBase)

Public Functions

MapReduceBase(QFutureInterface<ReduceResult> futureInterface, ForwardIterator begin, ForwardIterator end, MapFunction &&map, State &state, ReduceFunction &&reduce, MapReduceOption option, QThreadPool *pool, int size)
void exec()

Protected Functions

void cancelAll()
void mapFinished(QFutureWatcher<MapResult> *watcher)
virtual void reduce(QFutureWatcher<MapResult> *watcher, int index) = 0
bool schedule()
void updateProgress()

Member Function Documentation

MapReduceBase::MapReduceBase(QFutureInterface<ReduceResult> futureInterface, ForwardIterator begin, ForwardIterator end, MapFunction &&map, State &state, ReduceFunction &&reduce, MapReduceOption option, QThreadPool *pool, int size)

Default constructs an instance of MapReduceBase.

[protected] void MapReduceBase::cancelAll()

void MapReduceBase::exec()

[protected] void MapReduceBase::mapFinished(QFutureWatcher<MapResult> *watcher)

[pure virtual protected] void MapReduceBase::reduce(QFutureWatcher<MapResult> *watcher, int index)

[protected] bool MapReduceBase::schedule()

[protected] void MapReduceBase::updateProgress()