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     // Initialize random generator here
  10     srand(time(NULL));
  11
  12     m_file.setFileName("foo.dat");
  13     m_file.open(QIODevice::ReadOnly);
  14     in.setDevice(&m_file);
  15
  16     abort = false;
  17     prev = 0;
  18     this->pData = pData;
  19 }
  20
  21 WorkerThread::~WorkerThread()
  22 {
  23     std::cout << "WorkerThread::~WorkerThread()\n";
  24
  25     mutex.lock();
  26     abort = true;
  27     condition.wakeOne();
  28     mutex.unlock();
  29
  30     m_file.close();
  31
  32     wait();
  33 }
  34
  35 void WorkerThread::run(void)
  36 {
  37     float r;
  38
  39     // Loop
  40     while (!abort) {
  41         mutex.lock();
  42         if (pData->size() >= 667) {
  43             std::cout << "WorkerThread::run()\t[BLOCKED]\n";
  44             condition.wait(&mutex);
  45             mutex.unlock();
  46         }
  47         else {
  48             in >> r;
  49             pData->enqueue(r);
  50             mutex.unlock();
  51         }
  52     }
  53 }
  54
  55 void WorkerThread::setData(QQueue<float> *pData)
  56 {
  57     this->pData = pData;
  58 }
  59
  60 void WorkerThread::setFileName(QString fileName)
  61 {
  62     std::cout << "WorkerThread::setFileName()\n";
  63
  64     // Close old file
  65     m_file.close();
  66
  67     // Open new one
  68     m_file.setFileName(fileName);
  69     m_file.open(QIODevice::ReadOnly);
  70     in.setDevice(&m_file);
  71 }