#pragma once

#ifndef TTHREADMESSAGE_H

#define TTHREADMESSAGE_H

//! HOW TO USE: subclass TThread::Message (MyMessage, in example) defining what to execute in onDeliver method and than, to send a message to be executed in the main thread:

//  MyMessage().send();

#ifndef TNZCORE_LIGHT

#include <qmutex></qmutex>

#else

#include <windows.h></windows.h>

#endif

#undef DVAPI

#undef DVVAR

#ifdef TNZCORE_EXPORTS

#define DVAPI DV_EXPORT_API

#define DVVAR DV_EXPORT_VAR

#else

#define DVAPI DV_IMPORT_API

#define DVVAR DV_IMPORT_VAR

#endif

#include "tcommon.h"

namespace TThread

{

bool DVAPI isMainThread();

//This class is used for communication between different threads. Calling the 'send' method in a thread, the user defined method 'onDeliver' is executed in the mainThread.

//using 'sendblocking', the calling thread will block until the main thread has executed the onDeliver function.

//WARNING!! the sendblocking method will cause a deadlock if used in a executable without main loop! (such as composer, cleanupper, etc.)

//NOTE: if the 'send' is called in the main thread, ther onDeliver is executed immediately.

class DVAPI Message

{

public:

	Message();

	virtual ~Message(){};

	virtual Message *clone() const = 0;

	virtual void onDeliver() = 0;

	void send();

	void sendBlocking();

};

#ifdef TNZCORE_LIGHT

class DVAPI Mutex

{

public:

	HANDLE m_mutex;

	Mutex() { m_mutex = CreateMutex(NULL, FALSE, NULL); }

	~Mutex() { CloseHandle(m_mutex); }

	void lock() { WaitForSingleObject(

		m_mutex, // handle to mutex

		INFINITE); }

	void unlock() { ReleaseMutex(m_mutex); }

private:

	// not implemented

	Mutex(const Mutex &);

	Mutex &operator=(const Mutex &);

};

class DVAPI MutexLocker

{

	HANDLE m_mutex;

public:

	MutexLocker(Mutex *mutex) : m_mutex(mutex->m_mutex) { WaitForSingleObject(m_mutex, INFINITE); }

	~MutexLocker() { ReleaseMutex(m_mutex); }

};

#else

class DVAPI Mutex : public QMutex

{

public:

	Mutex() : QMutex(QMutex::Recursive) {}

private:

	// not implemented

	Mutex(const Mutex &);

	Mutex &operator=(const Mutex &);

};

typedef QMutexLocker MutexLocker;

#endif

} //namespace  TThread

//------------------------------------------------------------------------------

//------------------------------------------------------------------------------

#endif