qt/sphere-orbit-camera-gui/workerthread.cpp

   1 #include <cstdlib>
   2 #include <iostream>
   3
   4 #include "workerthread.h"
   5
   6 WorkerThread::WorkerThread(QObject *parent, QQueue<float> *pData)
   7     : QThread(parent)
   8 {
   9     qDebug("WorkerThread::WorkerThread()");
  10
  11     // Initialize random generator here
  12     srand(time(NULL));
  13
  14     m_file.setFileName("foo.dat");
  15     m_file.open(QIODevice::ReadOnly);
  16     in.setDevice(&m_file);
  17
  18     abort = false;
  19     prev = 0;
  20     this->pData = pData;
  21 }
  22
  23 WorkerThread::~WorkerThread()
  24 {
  25     qDebug("WorkerThread::~WorkerThread()");
  26
  27     mutex.lock();
  28     abort = true;
  29     condition.wakeOne();
  30     mutex.unlock();
  31
  32     m_file.close();
  33
  34     wait();
  35 }
  36
  37 void WorkerThread::run(void)
  38 {
  39     float r;
  40
  41     qDebug("WorkerThread::run()");
  42
  43     // Loop
  44     while (!abort) {
  45         mutex.lock();
  46         if (pData->size() >= 667) {
  47             qDebug("BLOCKED");
  48             condition.wait(&mutex);
  49             mutex.unlock();
  50         }
  51         else {
  52             in >> r;
  53             pData->enqueue(r);
  54             mutex.unlock();
  55         }
  56     }
  57 }
  58
  59 void WorkerThread::setData(QQueue<float> *pData)
  60 {
  61     qDebug("WorkerThread::setData()");
  62
  63     this->pData = pData;
  64 }
  65
  66 void WorkerThread::setFileName(QString fileName)
  67 {
  68     qDebug("WorkerThread::setFileName()");
  69
  70     // Close old file
  71     m_file.close();
  72
  73     // Caution: discard all old data in QQueue
  74     // Worst case scenario if you don't: frame read corruption
  75     pData->clear();
  76
  77     // Open new one
  78     m_file.setFileName(fileName);
  79     m_file.open(QIODevice::ReadOnly);
  80     in.setDevice(&m_file);
  81 }