#include <qtconcurrentmapkernel.h>

Class Description

template<typename ReducedResultType, typename Iterator, typename MapFunctor, typename ReduceFunctor, typename Reducer = ReduceKernel<ReduceFunctor, ReducedResultType, typename MapFunctor::result_type>>
class QtConcurrent::MappedReducedKernel< ReducedResultType, Iterator, MapFunctor, ReduceFunctor, Reducer >

Definition at line 97 of file qtconcurrentmapkernel.h.

Inheritance diagram for MappedReducedKernel< ReducedResultType, Iterator, MapFunctor, ReduceFunctor, Reducer >:

Public Types
typedef ReducedResultType	ReturnType

typedef ReducedResultType	ResultType

Public Types inherited from IterateKernel< Iterator, ReducedResultType >
typedef ReducedResultType	ResultType

Public Types inherited from ThreadEngine< ReducedResultType >
typedef ReducedResultType	ResultType

Public Member Functions
	MappedReducedKernel (Iterator begin, Iterator end, MapFunctor _map, ReduceFunctor _reduce, ReduceOptions reduceOptions)

	MappedReducedKernel (ReducedResultType initialValue, MapFunctor _map, ReduceFunctor _reduce)

bool	runIteration (Iterator it, int index, ReducedResultType *)

bool	runIterations (Iterator sequenceBeginIterator, int begin, int end, ReducedResultType *)

void	finish ()

bool	shouldThrottleThread ()

bool	shouldStartThread ()

ReducedResultType *	result ()

Public Member Functions inherited from IterateKernel< Iterator, ReducedResultType >
	IterateKernel (Iterator _begin, Iterator _end)

virtual	~IterateKernel ()

void	start ()

bool	shouldStartThread ()

ThreadFunctionResult	threadFunction ()

ThreadFunctionResult	forThreadFunction ()

ThreadFunctionResult	whileThreadFunction ()

Public Member Functions inherited from ThreadEngine< ReducedResultType >
QFutureInterface< ReducedResultType > *	futureInterfaceTyped ()

ReducedResultType *	startSingleThreaded ()

ReducedResultType *	startBlocking ()

QFuture< ReducedResultType >	startAsynchronously ()

void	asynchronousFinish ()

void	reportResult (const ReducedResultType *_result, int index=-1)

void	reportResults (const QVector< ReducedResultType > &_result, int index=-1, int count=-1)

Public Member Functions inherited from ThreadEngineBase
	ThreadEngineBase ()

virtual	~ThreadEngineBase ()

void	startSingleThreaded ()

void	startBlocking ()

void	startThread ()

bool	isCanceled ()

void	waitForResume ()

bool	isProgressReportingEnabled ()

void	setProgressValue (int progress)

void	setProgressRange (int minimum, int maximum)

void	acquireBarrierSemaphore ()

Public Member Functions inherited from QRunnable
	QRunnable ()

virtual	~QRunnable ()

bool	autoDelete () const

void	setAutoDelete (bool _autoDelete)

Additional Inherited Members
Public Attributes inherited from IterateKernel< Iterator, ReducedResultType >
const Iterator	begin

const Iterator	end

Iterator	current

QAtomicInt	currentIndex

bool	forIteration

QAtomicInt	iteratorThreads

int	iterationCount

bool	progressReportingEnabled

QAtomicInt	completed

Protected Attributes inherited from ThreadEngineBase
QFutureInterfaceBase *	futureInterface

QThreadPool *	threadPool

ThreadEngineBarrier	barrier

QtConcurrent::internal::ExceptionStore	exceptionStore

Member Typedef Documentation

typedef ReducedResultType ReturnType

Definition at line 104 of file qtconcurrentmapkernel.h.

typedef ReducedResultType ResultType

Definition at line 159 of file qtconcurrentmapkernel.h.

Constructor & Destructor Documentation

MappedReducedKernel	(	Iterator	begin,
		Iterator	end,
		MapFunctor	_map,
		ReduceFunctor	_reduce,
		ReduceOptions	reduceOptions
	)

inline

Definition at line 105 of file qtconcurrentmapkernel.h.

106 : IterateKernel<Iterator, ReducedResultType>(begin, end), reducedResult(), map(_map), reduce(_reduce), reducer(reduceOptions)

107 { }

QtConcurrent::IterateKernel< Iterator, ReducedResultType >::begin

const Iterator begin

Definition: qtconcurrentiteratekernel.h:319

QtConcurrent::IterateKernel< Iterator, ReducedResultType >::end

const Iterator end

Definition: qtconcurrentiteratekernel.h:320

MappedReducedKernel	(	ReducedResultType	initialValue,
		MapFunctor	_map,
		ReduceFunctor	_reduce
	)

inline

Definition at line 109 of file qtconcurrentmapkernel.h.

112 : reducedResult(initialValue), map(_map), reduce(_reduce)

113 { }

Member Function Documentation

bool runIteration	(	Iterator	it,
		int	index,
		ReducedResultType *
	)

inlinevirtual

Reimplemented from IterateKernel< Iterator, ReducedResultType >.

Definition at line 115 of file qtconcurrentmapkernel.h.

     {
         IntermediateResults<typename MapFunctor::result_type> results;
         results.begin = index;
         results.end = index + 1;
 
         results.vector.append(map(*it));
         reducer.runReduce(reduce, reducedResult, results);
         return false;
     }

bool runIterations	(	Iterator	sequenceBeginIterator,
		int	begin,
		int	end,
		ReducedResultType *
	)

inlinevirtual

Reimplemented from IterateKernel< Iterator, ReducedResultType >.

Definition at line 126 of file qtconcurrentmapkernel.h.

     {
         IntermediateResults<typename MapFunctor::result_type> results;
         results.begin = begin;
         results.end = end;
         results.vector.reserve(end - begin);
 
         Iterator it = sequenceBeginIterator;
         advance(it, begin);
         for (int i = begin; i < end; ++i) {
             results.vector.append(map(*(it)));
             advance(it, 1);
         }
 
         reducer.runReduce(reduce, reducedResult, results);
         return false;
     }

void finish ( )

inlinevirtual

Reimplemented from ThreadEngineBase.

Definition at line 144 of file qtconcurrentmapkernel.h.

     {
         reducer.finish(reduce, reducedResult);
     }

bool shouldThrottleThread ( )

inlinevirtual

Reimplemented from ThreadEngineBase.

Definition at line 149 of file qtconcurrentmapkernel.h.

     {
         return IterateKernel<Iterator, ReducedResultType>::shouldThrottleThread() || reducer.shouldThrottle();
     }

bool shouldStartThread ( )

inlinevirtual

Reimplemented from ThreadEngineBase.

Definition at line 154 of file qtconcurrentmapkernel.h.

     {
         return IterateKernel<Iterator, ReducedResultType>::shouldStartThread() && reducer.shouldStartThread();
     }

ReducedResultType* result ( )

inlinevirtual

Reimplemented from ThreadEngine< ReducedResultType >.

Definition at line 160 of file qtconcurrentmapkernel.h.

     {
         return &reducedResult;
     }

The documentation for this class was generated from the following file:

QtCore/qtconcurrentmapkernel.h

MappedReducedKernel< ReducedResultType, Iterator, MapFunctor, ReduceFunctor, Reducer > Class Template Reference

Class Description

Public Types

Public Member Functions

Additional Inherited Members

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation