#include <qtconcurrentiteratekernel.h>

Class Description

template<typename Iterator, typename T>
class QtConcurrent::IterateKernel< Iterator, T >

Definition at line 178 of file qtconcurrentiteratekernel.h.

Inheritance diagram for IterateKernel< Iterator, T >:

Public Types
typedef T	ResultType

Public Types inherited from ThreadEngine< T >
typedef T	ResultType

Public Member Functions
	IterateKernel (Iterator _begin, Iterator _end)

virtual	~IterateKernel ()

virtual bool	runIteration (Iterator it, int index, T *result)

virtual bool	runIterations (Iterator _begin, int beginIndex, int endIndex, T *results)

void	start ()

bool	shouldStartThread ()

ThreadFunctionResult	threadFunction ()

ThreadFunctionResult	forThreadFunction ()

ThreadFunctionResult	whileThreadFunction ()

Public Member Functions inherited from ThreadEngine< T >
virtual T *	result ()

QFutureInterface< T > *	futureInterfaceTyped ()

T *	startSingleThreaded ()

T *	startBlocking ()

QFuture< T >	startAsynchronously ()

void	asynchronousFinish ()

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

void	reportResults (const QVector< T > &_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)

Public Attributes
const Iterator	begin

const Iterator	end

Iterator	current

QAtomicInt	currentIndex

bool	forIteration

QAtomicInt	iteratorThreads

int	iterationCount

bool	progressReportingEnabled

QAtomicInt	completed

Additional Inherited Members
Protected Member Functions inherited from ThreadEngineBase
virtual void	finish ()

virtual bool	shouldThrottleThread ()

Protected Attributes inherited from ThreadEngineBase
QFutureInterfaceBase *	futureInterface

QThreadPool *	threadPool

ThreadEngineBarrier	barrier

QtConcurrent::internal::ExceptionStore	exceptionStore

Member Typedef Documentation

typedef T ResultType

Definition at line 181 of file qtconcurrentiteratekernel.h.

Constructor & Destructor Documentation

IterateKernel	(	Iterator	_begin,
		Iterator	_end
	)

inline

Definition at line 183 of file qtconcurrentiteratekernel.h.

         : begin(_begin), end(_end), current(_begin), currentIndex(0),
            forIteration(false), progressReportingEnabled(true)
 #else
         : begin(_begin), end(_end), current(_begin), currentIndex(0),
            forIteration(selectIteration(typename std::iterator_traits<Iterator>::iterator_category())), progressReportingEnabled(true)
 #endif
     {
 #if defined (QT_NO_STL)
        iterationCount = 0;
 #else
         iterationCount =  forIteration ? std::distance(_begin, _end) : 0;
 
 #endif
     }

virtual ~IterateKernel ( )

inlinevirtual

Definition at line 200 of file qtconcurrentiteratekernel.h.

200 { }

Member Function Documentation

virtual bool runIteration	(	Iterator	it,
		int	index,
		T *	result
	)

inlinevirtual

Reimplemented in FilteredReducedKernel< ReducedResultType, Iterator, KeepFunctor, ReduceFunctor, Reducer >, MappedEachKernel< Iterator, MapFunctor >, MappedReducedKernel< ReducedResultType, Iterator, MapFunctor, ReduceFunctor, Reducer >, and MapKernel< Iterator, MapFunctor >.

Definition at line 202 of file qtconcurrentiteratekernel.h.

203 { Q_UNUSED(it); Q_UNUSED(index); Q_UNUSED(result); return false; }

QtConcurrent::ThreadEngine::result

virtual T * result()

Definition: qtconcurrentthreadengine.h:143

index

GLuint index

Definition: GLee.h:1704

virtual bool runIterations	(	Iterator	_begin,
		int	beginIndex,
		int	endIndex,
		T *	results
	)

inlinevirtual

Reimplemented in FilteredReducedKernel< ReducedResultType, Iterator, KeepFunctor, ReduceFunctor, Reducer >, MappedEachKernel< Iterator, MapFunctor >, MappedReducedKernel< ReducedResultType, Iterator, MapFunctor, ReduceFunctor, Reducer >, and MapKernel< Iterator, MapFunctor >.

Definition at line 204 of file qtconcurrentiteratekernel.h.

205 { Q_UNUSED(_begin); Q_UNUSED(beginIndex); Q_UNUSED(endIndex); Q_UNUSED(results); return false; }

void start ( )

inlinevirtual

Reimplemented from ThreadEngineBase.

Definition at line 207 of file qtconcurrentiteratekernel.h.

     {
         progressReportingEnabled = this->isProgressReportingEnabled();
         if (progressReportingEnabled && iterationCount > 0)
             this->setProgressRange(0, iterationCount);
     }

bool shouldStartThread ( )

inlinevirtual

Reimplemented from ThreadEngineBase.

Definition at line 214 of file qtconcurrentiteratekernel.h.

     {
         if (forIteration)
             return (currentIndex < iterationCount) && !this->shouldThrottleThread();
         else // whileIteration
             return (iteratorThreads == 0);
     }

ThreadFunctionResult threadFunction ( )

inlinevirtual

Reimplemented from ThreadEngineBase.

Definition at line 222 of file qtconcurrentiteratekernel.h.

     {
         if (forIteration)
             return this->forThreadFunction();
         else // whileIteration
             return this->whileThreadFunction();
     }

ThreadFunctionResult forThreadFunction ( )

inline

Definition at line 230 of file qtconcurrentiteratekernel.h.

     {
         BlockSizeManager blockSizeManager(iterationCount);
         ResultReporter<T> resultReporter(this);
 
         for(;;) {
             if (this->isCanceled())
                 break;
 
             const int currentBlockSize = blockSizeManager.blockSize();
 
             if (currentIndex >= iterationCount)
                 break;
 
             // Atomically reserve a block of iterationCount for this thread.
             const int beginIndex = currentIndex.fetchAndAddRelease(currentBlockSize);
             const int endIndex = qMin(beginIndex + currentBlockSize, iterationCount);
 
             if (beginIndex >= endIndex) {
                 // No more work
                 break;
             }
 
             this->waitForResume(); // (only waits if the qfuture is paused.)
 
             if (shouldStartThread())
                 this->startThread();
 
             const int finalBlockSize = endIndex - beginIndex; // block size adjusted for possible end-of-range
             resultReporter.reserveSpace(finalBlockSize);
 
             // Call user code with the current iteration range.
             blockSizeManager.timeBeforeUser();
             const bool resultsAvailable = this->runIterations(begin, beginIndex, endIndex, resultReporter.getPointer());
             blockSizeManager.timeAfterUser();
 
             if (resultsAvailable)
                 resultReporter.reportResults(beginIndex);
 
             // Report progress if progress reporting enabled.
             if (progressReportingEnabled) {
                 completed.fetchAndAddAcquire(finalBlockSize);
                 this->setProgressValue(this->completed);
             }
 
             if (this->shouldThrottleThread())
                 return ThrottleThread;
         }
         return ThreadFinished;
     }

ThreadFunctionResult whileThreadFunction ( )

inline

Definition at line 281 of file qtconcurrentiteratekernel.h.

     {
         if (iteratorThreads.testAndSetAcquire(0, 1) == false)
             return ThreadFinished;
 
         ResultReporter<T> resultReporter(this);
         resultReporter.reserveSpace(1);
 
         while (current != end) {
             // The following two lines breaks support for input iterators according to
             // the sgi docs: dereferencing prev after calling ++current is not allowed
             // on input iterators. (prev is dereferenced inside user.runIteration())
             Iterator prev = current;
             ++current;
             int index = currentIndex.fetchAndAddRelaxed(1);
             iteratorThreads.testAndSetRelease(1, 0);
 
             this->waitForResume(); // (only waits if the qfuture is paused.)
 
             if (shouldStartThread())
                 this->startThread();
 
             const bool resultAavailable = this->runIteration(prev, index, resultReporter.getPointer());
             if (resultAavailable)
                 resultReporter.reportResults(index);
 
             if (this->shouldThrottleThread())
                 return ThrottleThread;
 
             if (iteratorThreads.testAndSetAcquire(0, 1) == false)
                 return ThreadFinished;
         }
 
         return ThreadFinished;
     }