#include "PolyThreaded.h"

#include "PolyCore.h"

using namespace Polycode;

Threaded::Threaded() : EventDispatcher() {

threadRunning = true;

scheduledForRemoval = false;

}

Threaded::~Threaded() {

core->removeThread(this);

}

void Threaded::killThread() {

threadRunning = false;

}

void Threaded::runThread(){

while(threadRunning) {

updateThread();

}

}

void Threaded::dispatchEvent(Event *event, int eventCode) {

core->lockMutex(eventMutex);

event->setEventCode(eventCode);

eventQueue.push_back(event);

core->unlockMutex(eventMutex);

}

void Threaded::dispatchEventNoDelete(Event *event, int eventCode) {

core->lockMutex(eventMutex);

event->setEventCode(eventCode);

event->deleteOnDispatch = false;

eventQueue.push_back(event);

core->unlockMutex(eventMutex);

}