C++ (Qt)
   ThreadFunctionResult forThreadFunction()
    {
        BlockSizeManagerV2 blockSizeManager(iterationCount);
        ResultReporter<T> resultReporter(this);
 
        for(;;) {
            if (this->isCanceled())
                break;
 
            const int currentBlockSize = blockSizeManager.blockSize();
 
            if (currentIndex.load() >= 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.load());
            }
 
            if (this->shouldThrottleThread())
                return ThrottleThread;
        }
        return ThreadFinished;
    }