Qt 4.8
Public Functions | Public Variables | List of all members
QFutureInterfaceBasePrivate Class Reference

#include <qfutureinterface_p.h>

Public Functions

void connectOutputInterface (QFutureCallOutInterface *iface)
 
void disconnectOutputInterface (QFutureCallOutInterface *iface)
 
bool internal_isResultReadyAt (int index) const
 
int internal_resultCount () const
 
void internal_setThrottled (bool enable)
 
bool internal_updateProgress (int progress, const QString &progressText=QString())
 
bool internal_waitForNextResult ()
 
 QFutureInterfaceBasePrivate (QFutureInterfaceBase::State initialState)
 
void sendCallOut (const QFutureCallOutEvent &callOut)
 
void sendCallOuts (const QFutureCallOutEvent &callOut1, const QFutureCallOutEvent &callOut2)
 
void setState (QFutureInterfaceBase::State state)
 

Public Variables

QtConcurrent::internal::ExceptionStore m_exceptionStore
 
int m_expectedResultCount
 
QMutex m_mutex
 
int m_progressMaximum
 
int m_progressMinimum
 
QString m_progressText
 
int m_progressValue
 
QtConcurrent::ResultStoreBase m_results
 
bool manualProgress
 
QList< QFutureCallOutInterface * > outputConnections
 
QWaitCondition pausedWaitCondition
 
int pendingResults
 
QElapsedTimer progressTime
 
QAtomicInt refCount
 
QRunnable * runnable
 
QFutureInterfaceBase::State state
 
QWaitCondition waitCondition
 

Detailed Description

Definition at line 127 of file qfutureinterface_p.h.

Constructors and Destructors

◆ QFutureInterfaceBasePrivate()

QFutureInterfaceBasePrivate::QFutureInterfaceBasePrivate ( QFutureInterfaceBase::State  initialState)

Definition at line 422 of file qfutureinterface.cpp.

423  : refCount(1), m_progressValue(0), m_progressMinimum(0), m_progressMaximum(0),
424  state(initialState), pendingResults(0),
425  manualProgress(false), m_expectedResultCount(0), runnable(0)
426 {
427  progressTime.invalidate();
428 }
QFutureInterfaceBasePrivate::state
QFutureInterfaceBase::State state
Definition: qfutureinterface_p.h:139
QElapsedTimer::invalidate
void invalidate()
Marks this QElapsedTimer object as invalid.
Definition: qelapsedtimer.cpp:245

Functions

◆ connectOutputInterface()

void QFutureInterfaceBasePrivate::connectOutputInterface ( QFutureCallOutInterface *  iface)

Definition at line 511 of file qfutureinterface.cpp.

512 {
513  QMutexLocker locker(&m_mutex);
514 
515  if (state & QFutureInterfaceBase::Started) {
516  interface->postCallOutEvent(QFutureCallOutEvent(QFutureCallOutEvent::Started));
517  interface->postCallOutEvent(QFutureCallOutEvent(QFutureCallOutEvent::ProgressRange,
518  m_progressMinimum,
519  m_progressMaximum));
520  interface->postCallOutEvent(QFutureCallOutEvent(QFutureCallOutEvent::Progress,
521  m_progressValue,
522  m_progressText));
523  }
524 
525  QtConcurrent::ResultIteratorBase it = m_results.begin();
526  while (it != m_results.end()) {
527  const int begin = it.resultIndex();
528  const int end = begin + it.batchSize();
529  interface->postCallOutEvent(QFutureCallOutEvent(QFutureCallOutEvent::ResultsReady,
530  begin,
531  end));
532  it.batchedAdvance();
533  }
534 
535  if (state & QFutureInterfaceBase::Paused)
536  interface->postCallOutEvent(QFutureCallOutEvent(QFutureCallOutEvent::Paused));
537 
538  if (state & QFutureInterfaceBase::Canceled)
539  interface->postCallOutEvent(QFutureCallOutEvent(QFutureCallOutEvent::Canceled));
540 
541  if (state & QFutureInterfaceBase::Finished)
542  interface->postCallOutEvent(QFutureCallOutEvent(QFutureCallOutEvent::Finished));
543 
544  outputConnections.append(interface);
545 }
it
#define it(className, varName)
Definition: qbuiltintypes.cpp:95
QFutureInterfaceBasePrivate::m_results
QtConcurrent::ResultStoreBase m_results
Definition: qfutureinterface_p.h:143
QFutureInterfaceBasePrivate::state
QFutureInterfaceBase::State state
Definition: qfutureinterface_p.h:139
QList::append
void append(const T &t)
Inserts value at the end of the list.
Definition: qlist.h:507
QFutureInterfaceBasePrivate::outputConnections
QList< QFutureCallOutInterface * > outputConnections
Definition: qfutureinterface_p.h:135
QMutexLocker
The QMutexLocker class is a convenience class that simplifies locking and unlocking mutexes...
Definition: qmutex.h:101
end
static const KeyPair *const end
Definition: qt_cocoa_helpers_mac.mm:652

◆ disconnectOutputInterface()

void QFutureInterfaceBasePrivate::disconnectOutputInterface ( QFutureCallOutInterface *  iface)

Definition at line 547 of file qfutureinterface.cpp.

548 {
549  QMutexLocker lock(&m_mutex);
550  const int index = outputConnections.indexOf(interface);
551  if (index == -1)
552  return;
553  outputConnections.removeAt(index);
554 
555  interface->callOutInterfaceDisconnected();
556 }
QFutureInterfaceBasePrivate::outputConnections
QList< QFutureCallOutInterface * > outputConnections
Definition: qfutureinterface_p.h:135
QMutexLocker
The QMutexLocker class is a convenience class that simplifies locking and unlocking mutexes...
Definition: qmutex.h:101
QList::indexOf
int indexOf(const T &t, int from=0) const
Returns the index position of the first occurrence of value in the list, searching forward from index...
Definition: qlist.h:847
Maemo::lock
static QReadWriteLock lock
Definition: proxyconf.cpp:399
index
quint16 index
Definition: qfontsubset.cpp:116
QList::removeAt
void removeAt(int i)
Removes the item at index position i.
Definition: qlist.h:480

◆ internal_isResultReadyAt()

bool QFutureInterfaceBasePrivate::internal_isResultReadyAt ( int  index) const

Definition at line 435 of file qfutureinterface.cpp.

Referenced by QFutureInterfaceBase::isResultReadyAt(), and QFutureInterfaceBase::waitForResult().

436 {
437  return (m_results.contains(index));
438 }
QFutureInterfaceBasePrivate::m_results
QtConcurrent::ResultStoreBase m_results
Definition: qfutureinterface_p.h:143
index
quint16 index
Definition: qfontsubset.cpp:116

◆ internal_resultCount()

int QFutureInterfaceBasePrivate::internal_resultCount ( ) const

Definition at line 430 of file qfutureinterface.cpp.

Referenced by QFutureInterfaceBase::resultCount().

431 {
432  return m_results.count(); // ### subtract canceled results.
433 }
QFutureInterfaceBasePrivate::m_results
QtConcurrent::ResultStoreBase m_results
Definition: qfutureinterface_p.h:143

◆ internal_setThrottled()

void QFutureInterfaceBasePrivate::internal_setThrottled ( bool  enable)

Definition at line 468 of file qfutureinterface.cpp.

469 {
470  // bail out if we are not changing the state
471  if ((enable && (state & QFutureInterfaceBase::Throttled))
472  || (!enable && !(state & QFutureInterfaceBase::Throttled)))
473  return;
474 
475  // change the state
476  if (enable) {
477  state = QFutureInterfaceBase::State(state | QFutureInterfaceBase::Throttled);
478  } else {
479  state = QFutureInterfaceBase::State(state & ~QFutureInterfaceBase::Throttled);
480  if (!(state & QFutureInterfaceBase::Paused))
481  pausedWaitCondition.wakeAll();
482  }
483 }
QFutureInterfaceBasePrivate::state
QFutureInterfaceBase::State state
Definition: qfutureinterface_p.h:139

◆ internal_updateProgress()

bool QFutureInterfaceBasePrivate::internal_updateProgress ( int  progress,
const QString &  progressText = QString() 
)

Definition at line 451 of file qfutureinterface.cpp.

Referenced by QFutureInterfaceBase::reportResultsReady(), and QFutureInterfaceBase::setProgressValueAndText().

453 {
454  if (m_progressValue >= progress)
455  return false;
456 
457  m_progressValue = progress;
458  m_progressText = progressText;
459 
460  if (progressTime.isValid() && m_progressValue != m_progressMaximum) // make sure the first and last steps are emitted.
461  if (progressTime.elapsed() < (1000 / MaxProgressEmitsPerSecond))
462  return false;
463 
464  progressTime.start();
465  return true;
466 }
QElapsedTimer::isValid
bool isValid() const
Returns false if this object was invalidated by a call to invalidate() and has not been restarted sin...
Definition: qelapsedtimer.cpp:256
QElapsedTimer::elapsed
qint64 elapsed() const
Returns the number of milliseconds since this QElapsedTimer was last started.
Definition: qelapsedtimer_generic.cpp:132
QElapsedTimer::start
void start()
Starts this timer.
Definition: qelapsedtimer_generic.cpp:79

◆ internal_waitForNextResult()

bool QFutureInterfaceBasePrivate::internal_waitForNextResult ( )

Definition at line 440 of file qfutureinterface.cpp.

Referenced by QFutureInterfaceBase::waitForNextResult().

441 {
442  if (m_results.hasNextResult())
443  return true;
444 
445  while ((state & QFutureInterfaceBase::Running) && m_results.hasNextResult() == false)
446  waitCondition.wait(&m_mutex);
447 
448  return (!(state & QFutureInterfaceBase::Canceled) && m_results.hasNextResult());
449 }
QFutureInterfaceBasePrivate::m_results
QtConcurrent::ResultStoreBase m_results
Definition: qfutureinterface_p.h:143
QFutureInterfaceBasePrivate::state
QFutureInterfaceBase::State state
Definition: qfutureinterface_p.h:139
QWaitCondition::wait
bool wait(QMutex *mutex, unsigned long time=ULONG_MAX)
Definition: qwaitcondition_unix.cpp:145

◆ sendCallOut()

void QFutureInterfaceBasePrivate::sendCallOut ( const QFutureCallOutEvent &  callOut)

Definition at line 485 of file qfutureinterface.cpp.

Referenced by QFutureInterfaceBase::cancel(), QFutureInterfaceBase::reportException(), QFutureInterfaceBase::reportFinished(), QFutureInterfaceBase::reportResultsReady(), QFutureInterfaceBase::reportStarted(), QFutureInterfaceBase::setPaused(), QFutureInterfaceBase::setProgressRange(), QFutureInterfaceBase::setProgressValueAndText(), and QFutureInterfaceBase::togglePaused().

486 {
487  if (outputConnections.isEmpty())
488  return;
489 
490  for (int i = 0; i < outputConnections.count(); ++i)
491  outputConnections.at(i)->postCallOutEvent(callOutEvent);
492 }
QFutureCallOutInterface::postCallOutEvent
virtual void postCallOutEvent(const QFutureCallOutEvent &)=0
QList::count
int count(const T &t) const
Returns the number of occurrences of value in the list.
Definition: qlist.h:891
QList::isEmpty
bool isEmpty() const
Returns true if the list contains no items; otherwise returns false.
Definition: qlist.h:152
QList::at
const T & at(int i) const
Returns the item at index position i in the list.
Definition: qlist.h:468
QFutureInterfaceBasePrivate::outputConnections
QList< QFutureCallOutInterface * > outputConnections
Definition: qfutureinterface_p.h:135

◆ sendCallOuts()

void QFutureInterfaceBasePrivate::sendCallOuts ( const QFutureCallOutEvent &  callOut1,
const QFutureCallOutEvent &  callOut2 
)

Definition at line 494 of file qfutureinterface.cpp.

Referenced by QFutureInterfaceBase::reportResultsReady().

496 {
497  if (outputConnections.isEmpty())
498  return;
499 
500  for (int i = 0; i < outputConnections.count(); ++i) {
501  QFutureCallOutInterface *interface = outputConnections.at(i);
502  interface->postCallOutEvent(callOutEvent1);
503  interface->postCallOutEvent(callOutEvent2);
504  }
505 }
at
#define at(className, varName)
Definition: qbuiltintypes.cpp:73
QList::count
int count(const T &t) const
Returns the number of occurrences of value in the list.
Definition: qlist.h:891
QList::isEmpty
bool isEmpty() const
Returns true if the list contains no items; otherwise returns false.
Definition: qlist.h:152
QFutureInterfaceBasePrivate::outputConnections
QList< QFutureCallOutInterface * > outputConnections
Definition: qfutureinterface_p.h:135

◆ setState()

void QFutureInterfaceBasePrivate::setState ( QFutureInterfaceBase::State  state)

Definition at line 558 of file qfutureinterface.cpp.

Referenced by QFutureInterfaceBase::reportStarted().

559 {
560  state = newState;
561 }
QFutureInterfaceBasePrivate::state
QFutureInterfaceBase::State state
Definition: qfutureinterface_p.h:139

Properties

◆ m_exceptionStore

QtConcurrent::internal::ExceptionStore QFutureInterfaceBasePrivate::m_exceptionStore

Definition at line 146 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::exceptionStore(), QFutureInterfaceBase::reportException(), QFutureInterfaceBase::waitForFinished(), and QFutureInterfaceBase::waitForResult().

◆ m_expectedResultCount

int QFutureInterfaceBasePrivate::m_expectedResultCount

Definition at line 145 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::expectedResultCount(), and QFutureInterfaceBase::setExpectedResultCount().

◆ m_mutex

QMutex QFutureInterfaceBasePrivate::m_mutex
mutable

Definition at line 133 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::cancel(), connectOutputInterface(), disconnectOutputInterface(), internal_waitForNextResult(), QFutureInterfaceBase::isProgressUpdateNeeded(), QFutureInterfaceBase::isResultReadyAt(), QFutureInterfaceBase::mutex(), QFutureInterfaceBase::progressText(), QFutureInterfaceBase::reportException(), QFutureInterfaceBase::reportFinished(), QFutureInterfaceBase::reportStarted(), QFutureInterfaceBase::resultCount(), QFutureInterfaceBase::setFilterMode(), QFutureInterfaceBase::setPaused(), QFutureInterfaceBase::setProgressRange(), QFutureInterfaceBase::setProgressValueAndText(), QFutureInterfaceBase::setThrottled(), QFutureInterfaceBase::togglePaused(), QFutureInterfaceBase::waitForFinished(), QFutureInterfaceBase::waitForNextResult(), QFutureInterfaceBase::waitForResult(), and QFutureInterfaceBase::waitForResume().

◆ m_progressMaximum

int QFutureInterfaceBasePrivate::m_progressMaximum

Definition at line 138 of file qfutureinterface_p.h.

Referenced by connectOutputInterface(), internal_updateProgress(), QFutureInterfaceBase::progressMaximum(), and QFutureInterfaceBase::setProgressRange().

◆ m_progressMinimum

int QFutureInterfaceBasePrivate::m_progressMinimum

Definition at line 137 of file qfutureinterface_p.h.

Referenced by connectOutputInterface(), QFutureInterfaceBase::progressMinimum(), and QFutureInterfaceBase::setProgressRange().

◆ m_progressText

QString QFutureInterfaceBasePrivate::m_progressText

Definition at line 147 of file qfutureinterface_p.h.

Referenced by connectOutputInterface(), internal_updateProgress(), QFutureInterfaceBase::progressText(), QFutureInterfaceBase::reportResultsReady(), and QFutureInterfaceBase::setProgressValueAndText().

◆ m_progressValue

int QFutureInterfaceBasePrivate::m_progressValue

Definition at line 136 of file qfutureinterface_p.h.

Referenced by connectOutputInterface(), internal_updateProgress(), QFutureInterfaceBase::progressValue(), QFutureInterfaceBase::reportResultsReady(), and QFutureInterfaceBase::setProgressValueAndText().

◆ m_results

QtConcurrent::ResultStoreBase QFutureInterfaceBasePrivate::m_results

Definition at line 143 of file qfutureinterface_p.h.

Referenced by connectOutputInterface(), internal_isResultReadyAt(), internal_resultCount(), internal_waitForNextResult(), and QFutureInterfaceBase::resultStoreBase().

◆ manualProgress

bool QFutureInterfaceBasePrivate::manualProgress

Definition at line 144 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::reportResultsReady(), QFutureInterfaceBase::setExpectedResultCount(), and QFutureInterfaceBase::setProgressValueAndText().

◆ outputConnections

QList<QFutureCallOutInterface *> QFutureInterfaceBasePrivate::outputConnections

Definition at line 135 of file qfutureinterface_p.h.

Referenced by connectOutputInterface(), disconnectOutputInterface(), sendCallOut(), and sendCallOuts().

◆ pausedWaitCondition

QWaitCondition QFutureInterfaceBasePrivate::pausedWaitCondition

Definition at line 141 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::cancel(), internal_setThrottled(), QFutureInterfaceBase::reportException(), QFutureInterfaceBase::setPaused(), QFutureInterfaceBase::setThrottled(), QFutureInterfaceBase::togglePaused(), and QFutureInterfaceBase::waitForResume().

◆ pendingResults

int QFutureInterfaceBasePrivate::pendingResults

Definition at line 142 of file qfutureinterface_p.h.

◆ progressTime

QElapsedTimer QFutureInterfaceBasePrivate::progressTime

Definition at line 140 of file qfutureinterface_p.h.

Referenced by internal_updateProgress(), QFutureInterfaceBase::isProgressUpdateNeeded(), and QFutureInterfaceBasePrivate().

◆ refCount

QAtomicInt QFutureInterfaceBasePrivate::refCount

Definition at line 132 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::operator=(), QFutureInterfaceBase::QFutureInterfaceBase(), QFutureInterfaceBase::referenceCountIsOne(), and QFutureInterfaceBase::~QFutureInterfaceBase().

◆ runnable

QRunnable* QFutureInterfaceBasePrivate::runnable

Definition at line 148 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::setRunnable(), QFutureInterfaceBase::waitForFinished(), and QFutureInterfaceBase::waitForResult().

◆ state

QFutureInterfaceBase::State QFutureInterfaceBasePrivate::state

Definition at line 139 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::cancel(), connectOutputInterface(), internal_setThrottled(), internal_waitForNextResult(), QFutureInterfaceBase::queryState(), QFutureInterfaceBase::reportException(), QFutureInterfaceBase::reportFinished(), QFutureInterfaceBase::reportResultsReady(), QFutureInterfaceBase::reportStarted(), QFutureInterfaceBase::setPaused(), QFutureInterfaceBase::setProgressValueAndText(), setState(), QFutureInterfaceBase::setThrottled(), QFutureInterfaceBase::togglePaused(), QFutureInterfaceBase::waitForFinished(), QFutureInterfaceBase::waitForResult(), and QFutureInterfaceBase::waitForResume().

◆ waitCondition

QWaitCondition QFutureInterfaceBasePrivate::waitCondition

Definition at line 134 of file qfutureinterface_p.h.

Referenced by QFutureInterfaceBase::cancel(), internal_waitForNextResult(), QFutureInterfaceBase::reportException(), QFutureInterfaceBase::reportFinished(), QFutureInterfaceBase::reportResultsReady(), QFutureInterfaceBase::waitForFinished(), and QFutureInterfaceBase::waitForResult().

The documentation for this class was generated from the following files:
Qt 4.8 Source Code Browser