sphere-orbit/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     abort = false;
  13     prev = 0;
  14     this->pData = pData;
  15 }
  16
  17 WorkerThread::~WorkerThread()
  18 {
  19     mutex.lock();
  20     abort = true;
  21     condition.wakeOne();
  22     mutex.unlock();
  23
  24     wait();
  25 }
  26
  27 void WorkerThread::run(void)
  28 {
  29     float r;
  30
  31     // Loop
  32     while (!abort) {
  33         r = 3.0 * (float) rand() / RAND_MAX;
  34         r += prev;
  35         prev = r;
  36         //std::cout << "r = " << r << std::endl;
  37         mutex.lock();
  38         if (pData->size() > 100) {
  39             std::cout << "WorkerThread::run()\t[BLOCKED]\n";
  40             condition.wait(&mutex);
  41             mutex.unlock();
  42         }
  43         else {
  44             pData->enqueue(r);
  45             mutex.unlock();
  46         }
  47     }
  48 }
  49
  50 void WorkerThread::setData(QQueue<float> *pData)
  51 {
  52     this->pData = pData;
  53 }