We are currently migrating Bugzilla to GitHub issues.
Any changes made to the bug tracker now will be lost, so please do not post new bugs or make changes to them.
When we're done, all bug URLs will redirect to their equivalent location on the new bug tracker.

Persistent thread C++ object

Thread.h (text/plain), 2.47 KB, created by spamcatcher on 2009-11-02 01:16:54 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: spamcatcher

Created: 2009-11-02 01:16:54 UTC

Size: 2.47 KB

patch

obsolete

>#pragma once
>
>#include <SDL.h>
>#include <SDL_Thread.h>
>static int waiting;
>
>template <typename T> class Thread
>{
>	typedef void (T::*funcPtr)(void *);
>
>	SDL_cond *beginWork;
>	SDL_cond *finishedWork;
>	SDL_mutex *locker;
>	SDL_Thread *thread;
>	T *object;
>	funcPtr objFunc;
>	void *data;
>
>
>	bool run;
>	bool executing;
>	int *refCount;
>
>	static int ProxyThreadFunc(void *threadInfo) {
>		Thread<T> *ti = (Thread<T>*)threadInfo;
>		while(ti->run) {
>			ti->WaitBegin();
>			ti->lock();
>			ti->executing = true;
>			T *o = ti->object;
>			funcPtr f= ti->objFunc;
>			(o->*f)(ti->data);
>			ti->SignalComplete();
>			ti->executing = false;
>			ti->unlock();
>		}
>		return 0;
>	}
>
>	bool SignalComplete() {
>		int i = SDL_CondBroadcast(finishedWork);
>		waiting--;
>		return true;
>	}
>
>	void WaitBegin() {
>		waitSig(beginWork);
>		waiting++;
>	}
>
>	bool SignalBegin() {
>		SDL_CondBroadcast(beginWork);
>		return true;
>	}
>
>	void lock() {
>		SDL_mutexP(locker);
>	}
>
>	void unlock() {
>		SDL_mutexV(locker);
>	}
>
>	void waitSig(SDL_cond *s) {
>		int i = 1;
>		while (i != 0) {
>			lock();
>			i = SDL_CondWaitTimeout(s, locker, 1);
>			unlock();
>			if (i == -1) exit(2);
>		}
>	}
>
>	void waitSigExec(SDL_cond *s) {
>		int i = 1;
>		while (i != 0) {
>			lock();
>			i = SDL_CondWaitTimeout(s, locker, 1);
>			unlock();
>			if (i == -1) exit(2);
>			if (executing == false)
>				break;
>		}
>	}
>
>	Thread(const Thread<T> &other) {		
>		*this = other;
>	}
>
>	Thread<T> & operator = (const Thread<T> & other) {
>		beginWork = other.beginWork;
>		data = other.data;
>		executing = other.executing;
>		finishedWork = other.finishedWork;
>		locker = other.locker;
>		object =  other.object;
>		objFunc = other.objFunc;
>		run = other.run;
>		refCount = other.refCount;
>		(*refCount)++;
>		return *this;
>	}
>
>public:
>	Thread(void):run(true), executing(false),refCount(0) {
>		beginWork = SDL_CreateCond();
>		finishedWork = SDL_CreateCond();
>		locker = SDL_CreateMutex();
>		thread = SDL_CreateThread(ProxyThreadFunc, (void*)this);
>		refCount = new int;
>		*refCount = 1;
>	}
>
>
>	virtual ~Thread(void) {
>		if (--*refCount == 0) {
>			run = false;
>			SDL_KillThread(thread);
>			SDL_DestroyCond(beginWork);
>			SDL_DestroyCond(finishedWork);
>			delete refCount;
>		}
>	}
>
>	int Run(T *obj, funcPtr func, void*objData) {
>		lock();
>		object = obj;
>		objFunc = func;
>		data = objData;
>		SignalBegin();
>		unlock();
>		return 1;
>	}
>
>	int Wait() {
>		waitSig(finishedWork);
>		return 1;
>	}
>};

Actions: View

Attachments on bug 873: 442

We are currently migrating Bugzilla to GitHub issues.Any changes made to the bug tracker now will be lost, so please do not post new bugs or make changes to them.When we're done, all bug URLs will redirect to their equivalent location on the new bug tracker.

We are currently migrating Bugzilla to GitHub issues.
Any changes made to the bug tracker now will be lost, so please do not post new bugs or make changes to them.
When we're done, all bug URLs will redirect to their equivalent location on the new bug tracker.