//// GenericThread.cpp// shared//// Created by Brad Hefta-Gaub on 8/12/13.// Copyright (c) 2013 High Fidelity, Inc. All rights reserved.//// Generic Threaded or non-threaded processing class//#include "GenericThread.h"GenericThread::GenericThread() : _stopThread(false), _isThreaded(false) // assume non-threaded, must call initialize(){}GenericThread::~GenericThread() { terminate();}void GenericThread::initialize(bool isThreaded) { _isThreaded = isThreaded; if (_isThreaded) { QThread* _thread = new QThread(this); // when the worker thread is started, call our engine's run.. connect(_thread, SIGNAL(started()), this, SLOT(threadRoutine())); // XXXBHG: this is a known memory leak/thread leak. I will fix this shortly. //connect(this, SIGNAL(finished()), this, SLOT(deleteLater())); //connect(_thread, SIGNAL(finished()), _thread, SLOT(deleteLater())); this->moveToThread(_thread); // Starts an event loop, and emits _thread->started() _thread->start(); }}void GenericThread::terminate() { if (_isThreaded) { _stopThread = true; //_isThreaded = false; }}void GenericThread::threadRoutine() { while (!_stopThread) { // override this function to do whatever your class actually does, return false to exit thread early if (!process()) { break; } // In non-threaded mode, this will break each time you call it so it's the // callers responsibility to continuously call this method if (!_isThreaded) { break; } } if (_isThreaded) { emit finished(); }}
//
// GenericThread.cpp
// shared
//
// Created by Brad Hefta-Gaub on 8/12/13.
// Copyright (c) 2013 High Fidelity, Inc. All rights reserved.
//
// Generic Threaded or non-threaded processing class
//
#include "GenericThread.h"
GenericThread::GenericThread() :
_stopThread(false),
_isThreaded(false) // assume non-threaded, must call initialize()
{
}
GenericThread::~GenericThread() {
terminate();
}
void GenericThread::initialize(bool isThreaded) {
_isThreaded = isThreaded;
if (_isThreaded) {
QThread* _thread = new QThread(this);
// when the worker thread is started, call our engine's run..
connect(_thread, SIGNAL(started()), this, SLOT(threadRoutine()));
// XXXBHG: this is a known memory leak/thread leak. I will fix this shortly.
//connect(this, SIGNAL(finished()), this, SLOT(deleteLater()));
//connect(_thread, SIGNAL(finished()), _thread, SLOT(deleteLater()));
this->moveToThread(_thread);
// Starts an event loop, and emits _thread->started()
_thread->start();
}
}
void GenericThread::terminate() {
if (_isThreaded) {
_stopThread = true;
//_isThreaded = false;
}
}
void GenericThread::threadRoutine() {
while (!_stopThread) {
// override this function to do whatever your class actually does, return false to exit thread early
if (!process()) {
break;
}
// In non-threaded mode, this will break each time you call it so it's the
// callers responsibility to continuously call this method
if (!_isThreaded) {
break;
}
}
if (_isThreaded) {
emit finished();
}
}