workerthread.cpp

Go to the documentation of this file.

#include <app/workerthread.h>

using namespace frechet;
using namespace app;

void WorkerJobHandle::startJob(WorkerJob* new_job)
{
    QMutexLocker guard(&mut);
    if (job) job->cancelRequested=true;
    job = new_job;
    job->handle = this;
    job->cancelRequested = false;
    QThreadPool::globalInstance()->start(job);    
}


void WorkerJobHandle::invalidate(WorkerJob *ajob)
{
    QMutexLocker guard(&mut);
    if (ajob==job) job = NULL;
}
void WorkerJobHandle::cancelJob()
{
    QMutexLocker guard(&mut);
    if (job) job->cancelRequested=true;
}

void WorkerJobHandle::shutDown() {
    cancelJob();
    QThreadPool::globalInstance()->waitForDone();
}


void WorkerJob::run() {
    try {
        runJob();
    } catch(InterruptedException&) {
        afterInterrupted();
    } catch(...) {
        std::cerr << "An Error occured" << std::endl;
    }
    handle->invalidate(this);
    //  Note: deletion is delegated to QThreadPool
}