glest-source/source/shared_lib/include/platform/sdl/thread.h

// ==============================================================
//	This file is part of Glest Shared Library (www.glest.org)
//
//	Copyright (C) 2005 Matthias Braun <matze@braunis.de>
//
//	You can redistribute this code and/or modify it under 
//	the terms of the GNU General Public License as published 
//	by the Free Software Foundation; either version 2 of the 
//	License, or (at your option) any later version
// ==============================================================

#ifndef _SHARED_PLATFORM_THREAD_H_
#define _SHARED_PLATFORM_THREAD_H_

#include <SDL_thread.h>
#include <SDL_mutex.h>
#include "leak_dumper.h"

// =====================================================
//	class Thread
// =====================================================

namespace Shared{ namespace Platform{

class Thread{
public:
	enum Priority {
		pIdle = 0,
		pLow = 1,
		pNormal = 2,
		pHigh = 3,
		pRealTime = 4
	};
	
private:
	SDL_Thread* thread;

public:
	Thread();
	virtual ~Thread();
	
	void start();
	virtual void execute()=0;
	void setPriority(Thread::Priority threadPriority);	
	void suspend();
	void resume();

private:
	static int beginExecution(void *param);
};

// =====================================================
//	class Mutex
// =====================================================

class Mutex {
private:
	SDL_mutex* mutex;

public:
	Mutex();
	~Mutex();
	void p();
	void v();
};

class MutexSafeWrapper {
protected:
	Mutex *mutex;
public:

	MutexSafeWrapper(Mutex *mutex) {
		this->mutex = mutex;
		Lock();
	}
	~MutexSafeWrapper() {
		ReleaseLock();
	}

	void Lock() {
		if(this->mutex != NULL) {
			this->mutex->p();
		}
	}
	void ReleaseLock(bool keepMutex=false) {
		if(this->mutex != NULL) {
			this->mutex->v();
			if(keepMutex == false) {
				this->mutex = NULL;
			}
		}
	}
};

// =====================================================
//	class Semaphore
// =====================================================

class Semaphore {
private:
	SDL_sem* semaphore;

public:
	Semaphore(Uint32 initialValue = 0);
	~Semaphore();
	void signal();
	int waitTillSignalled();
};

}}//end namespace

#endif