//// GenericThread.cpp// libraries/shared/src//// Created by Brad Hefta-Gaub on 8/12/13.// Copyright 2013 High Fidelity, Inc.//// Distributed under the Apache License, Version 2.0.// See the accompanying file LICENSE or http://www.apache.org/licenses/LICENSE-2.0.html//#include <QDebug>#include "GenericThread.h"GenericThread::GenericThread() : _stopThread(false), _isThreaded(false) // assume non-threaded, must call initialize(){}GenericThread::~GenericThread() { // we only need to call terminate() if we're actually threaded and still running if (isStillRunning() && isThreaded()) { terminate(); }}void GenericThread::initialize(bool isThreaded) { _isThreaded = isThreaded; if (_isThreaded) { _thread = new QThread(this); // match the thread name to our object name _thread->setObjectName(objectName()); // when the worker thread is started, call our engine's run.. connect(_thread, SIGNAL(started()), this, SLOT(threadRoutine())); this->moveToThread(_thread); // Starts an event loop, and emits _thread->started() _thread->start(); }}void GenericThread::terminate() { if (_isThreaded) { _stopThread = true; terminating(); if (_thread) { _thread->wait(); _thread->deleteLater(); _thread = NULL; } }}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 we were on a thread, then quit our thread if (_isThreaded && _thread) { _thread->quit(); } emit finished();}
//
// GenericThread.cpp
// libraries/shared/src
//
// Created by Brad Hefta-Gaub on 8/12/13.
// Copyright 2013 High Fidelity, Inc.
//
// Distributed under the Apache License, Version 2.0.
// See the accompanying file LICENSE or http://www.apache.org/licenses/LICENSE-2.0.html
//
#include <QDebug>
#include "GenericThread.h"
GenericThread::GenericThread() :
_stopThread(false),
_isThreaded(false) // assume non-threaded, must call initialize()
{
}
GenericThread::~GenericThread() {
// we only need to call terminate() if we're actually threaded and still running
if (isStillRunning() && isThreaded()) {
terminate();
}
}
void GenericThread::initialize(bool isThreaded) {
_isThreaded = isThreaded;
if (_isThreaded) {
_thread = new QThread(this);
// match the thread name to our object name
_thread->setObjectName(objectName());
// when the worker thread is started, call our engine's run..
connect(_thread, SIGNAL(started()), this, SLOT(threadRoutine()));
this->moveToThread(_thread);
// Starts an event loop, and emits _thread->started()
_thread->start();
}
}
void GenericThread::terminate() {
if (_isThreaded) {
_stopThread = true;
terminating();
if (_thread) {
_thread->wait();
_thread->deleteLater();
_thread = NULL;
}
}
}
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 we were on a thread, then quit our thread
if (_isThreaded && _thread) {
_thread->quit();
}
emit finished();
}