#include <qxrdresultserializer.h>

Inheritance diagram for QxrdResultSerializer< T >:

[legend]

Collaboration diagram for QxrdResultSerializer< T >:

[legend]

Public Member Functions
	QxrdResultSerializer (QcepIntProperty ctr, QcepObject parent)

void	enqueue (QFuture< T > future)

T	dequeue ()

int	count () const

Public Member Functions inherited from QxrdResultSerializerBase
	QxrdResultSerializerBase (QcepObject *parent)

virtual	~QxrdResultSerializerBase ()

Public Member Functions inherited from QcepObject
	QcepObject (QString name, QcepObject *parent)

virtual	~QcepObject ()

virtual void	writeSettings (QSettings *set, QString section)

virtual void	readSettings (QSettings *set, QString section)

QString	get_Name () const

void	set_Name (QString name)

Private Attributes
QQueue< QFuture< T > >	m_Results

QFutureWatcher< T >	m_Watcher

QcepIntProperty *	m_Counter

Additional Inherited Members
Public Slots inherited from QcepObject
virtual void	printLine (QString line)

virtual void	printMessage (QString msg, QDateTime dt=QDateTime::currentDateTime()) const

virtual void	criticalMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

virtual void	statusMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

virtual QString	settingsScript ()

QString	scriptValueLiteral (QVariant v)

Signals inherited from QxrdResultSerializerBase
void	resultAvailable ()

Static Public Member Functions inherited from QcepObject
static int	allocatedObjects ()

static int	deletedObjects ()

static QSet< QcepObject * >	allocatedObjectsSet ()

static QString	addSlashes (QString str)

Protected Attributes inherited from QxrdResultSerializerBase
QMutex	m_Mutex

Properties inherited from QcepObject
QString	name

Detailed Description

template<typename T>
class QxrdResultSerializer< T >

Definition at line 28 of file qxrdresultserializer.h.

Constructor & Destructor Documentation

template<typename T >

QxrdResultSerializer< T >::QxrdResultSerializer	(	QcepIntProperty *	ctr,
		QcepObject *	parent
	)

explicit

Definition at line 15 of file qxrdresultserializer.cpp.

References QxrdResultSerializer< T >::m_Watcher, and QxrdResultSerializerBase::resultAvailable().

  : QxrdResultSerializerBase(parent),
    m_Counter(ctr)
 {
   connect(&m_Watcher, &QFutureWatcherBase::finished, this, &QxrdResultSerializerBase::resultAvailable);
 }

Member Function Documentation

template<typename T >

int QxrdResultSerializer< T >::count ( ) const

Definition at line 63 of file qxrdresultserializer.cpp.

 {
   QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);
 
   return m_Results.size();
 }

template<typename T >

T QxrdResultSerializer< T >::dequeue ( )

Definition at line 37 of file qxrdresultserializer.cpp.

Referenced by QxrdDataProcessorThreaded::onCorrectedImageAvailable(), QxrdDataProcessorThreaded::onHistogramDataAvailable(), QxrdDataProcessorThreaded::onIntegratedDataAvailable(), and QxrdDataProcessorThreaded::onROIDataAvailable().

 {
   QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);
 
   if (m_Results.size() > 0) {
     QFuture<T> val = m_Results.dequeue();
 
     if (m_Results.size() > 0) {
       m_Watcher.setFuture(m_Results[0]);
     }
 
     if (m_Counter) {
       m_Counter->incValue(-1);
     }
 
     return val.result();
   } else {
     if (m_Counter) {
       m_Counter->setValue(0);
     }
 
     return T();
   }
 }

Here is the caller graph for this function:

template<typename T>

void QxrdResultSerializer< T >::enqueue ( QFuture< T > future )

Definition at line 23 of file qxrdresultserializer.cpp.

Referenced by QxrdDataProcessorThreaded::acquiredDoubleImage(), QxrdDataProcessorThreaded::acquiredInt16Image(), QxrdDataProcessorThreaded::acquiredInt32Image(), QxrdDataProcessorThreaded::integrateData(), QxrdDataProcessorThreaded::integrateSaveAndDisplay(), QxrdDataProcessorThreaded::onCorrectedImageAvailable(), and QxrdDataProcessorThreaded::slicePolygon().

 {
   QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);
 
   m_Results.enqueue(future);
 
   m_Watcher.setFuture(m_Results[0]);
 
   if (m_Counter) {
     m_Counter->incValue(1);
   }
 }

Here is the caller graph for this function:

Member Data Documentation

template<typename T>

QcepIntProperty* QxrdResultSerializer< T >::m_Counter

private

Definition at line 43 of file qxrdresultserializer.h.

template<typename T>

QQueue< QFuture<T> > QxrdResultSerializer< T >::m_Results

private

Definition at line 41 of file qxrdresultserializer.h.

template<typename T>

QFutureWatcher<T> QxrdResultSerializer< T >::m_Watcher

private

Definition at line 42 of file qxrdresultserializer.h.

Referenced by QxrdResultSerializer< T >::QxrdResultSerializer().

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

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

template<typename T> class QxrdResultSerializer< T >

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

template<typename T>
class QxrdResultSerializer< T >