workerthread.h

Go to the documentation of this file.

#ifndef WORKERTHREAD_H
#define WORKERTHREAD_H

#include <QRunnable>
#include <QMutex>
#include <QThreadPool>

#include <iostream>
#include <freespace.h>

namespace frechet { namespace app {

class WorkerJobHandle;

class InterruptedException : public std::exception {

};

class WorkerJob : public QRunnable
{
private:
    friend class WorkerJobHandle;
    WorkerJobHandle* handle;
public:

    volatile bool cancelRequested;

    virtual void runJob()=0;
    virtual void afterInterrupted()=0;

    virtual void run() override;
};

class WorkerJobHandle
{
private:
    QMutex mut;
    WorkerJob* job;
public:
    WorkerJobHandle() : mut(), job(NULL) { }
    void startJob(WorkerJob* new_job);
    void cancelJob();
    void invalidate(WorkerJob* ajob);
    void shutDown();
};



} } //  namespaces

#endif // WORKERTHREAD_H