qxrdresultserializer.cpp

Go to the documentation of this file.

#include "qxrdresultserializer.h"
#include "qcepmutexlocker.h"

QxrdResultSerializerBase::QxrdResultSerializerBase(QcepObject *parent) :
    QcepObject("resultSerializer", parent)
{
}

QxrdResultSerializerBase::~QxrdResultSerializerBase()
{
}


template <typename T>
QxrdResultSerializer<T>::QxrdResultSerializer(QcepIntProperty *ctr, QcepObject *parent)
 : QxrdResultSerializerBase(parent),
   m_Counter(ctr)
{
  connect(&m_Watcher, &QFutureWatcherBase::finished, this, &QxrdResultSerializerBase::resultAvailable);
}

template <typename T>
void QxrdResultSerializer<T>::enqueue(QFuture<T> future)
{
  QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

  m_Results.enqueue(future);

  m_Watcher.setFuture(m_Results[0]);

  if (m_Counter) {
    m_Counter->incValue(1);
  }
}

template <typename T>
T QxrdResultSerializer<T>::dequeue()
{
  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();
  }
}

template <typename T>
int QxrdResultSerializer<T>::count() const
{
  QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

  return m_Results.size();
}

#include "qcepimagedata.h"
#include "qcepimagedata-ptr.h"
#include "qcepintegrateddata.h"
#include "qcepintegrateddata-ptr.h"
#include "qxrdroidata.h"
#include "qxrdroidata-ptr.h"
#include "qxrdhistogramdata.h"
#include "qxrdhistogramdata-ptr.h"

template class QxrdResultSerializer<QcepDoubleImageDataPtr>;
template class QxrdResultSerializer<QcepIntegratedDataPtr>;
template class QxrdResultSerializer<QxrdROIDataPtr>;
template class QxrdResultSerializer<QxrdHistogramDataPtr>;