E:/3pg/Studium/TU Wien/08 09 Wintersemester/Visualisierung/Aufgabe2/src_doxygen/FlowDataWorker.h

Go to the documentation of this file.

#ifndef FlowDataWorker_H
#define FlowDataWorker_H

#include <QString>
#include <QObject>
#include <QSize>
#include <QThread>
#include <QMutex>
#include <QMutexLocker>

#include "FlowData.h"
#include "Vector3.h"

template<class T> class FlowDataWorker : public QThread
{
public:
        FlowDataWorker(QObject *object);
        ~FlowDataWorker();

        void setFlowData(FlowData *flowData);
        void setSize(QSize size);

        T* getData();

protected:
        void stopCalculate();

        QObject *object;
        FlowData *flowData;
        QSize size;
        T *data;
        QMutex mutex;
};

class FlowDataWorkerVector : public FlowDataWorker<Vector3>
{
public:
        FlowDataWorkerVector(QObject *object);

        void calculate();

private:
        void run();
};

class FlowDataWorkerScalar : public FlowDataWorker<float>
{
public:
        FlowDataWorkerScalar(QObject *object);

        void setScalarIndex(int scalarIndex);

        void calculate();

private:
        void run();

        int scalarIndex;
        bool calculating;
};

// ### FlowDataWorker ###

template<class T> FlowDataWorker<T>::FlowDataWorker(QObject *object)
{
        this->object = object;
        flowData = 0;
        data = 0;
}

template<class T> FlowDataWorker<T>::~FlowDataWorker()
{
        QMutexLocker locker(&mutex);
        if(data != 0)
        {
                delete [] data;
                data = 0;
        }
}

template<class T> void FlowDataWorker<T>::setFlowData(FlowData *flowData)
{
        QMutexLocker locker(&mutex);
        this->flowData = flowData;
}

template<class T> void FlowDataWorker<T>::setSize(QSize size)
{
        QMutexLocker locker(&mutex);
        this->size = size;
}

template<class T> T* FlowDataWorker<T>::getData()
{
        QMutexLocker locker(&mutex);
        T *tempData = data;
        data = 0;

        return tempData;
}

template<class T> void FlowDataWorker<T>::stopCalculate()
{
        // TODO: stop threads
        /*if(newData != 0)
        {
                delete [] newData;
                newData = 0;
        }*/
}

#endif // FlowDataWorker_H

---