35e409e926
Found via `codespell -q 3 -S *.ts,thirdparty, -L appy,ba,inbetween,inout,pevent,possibile,upto`
104 lines
2.3 KiB
C++
104 lines
2.3 KiB
C++
#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>
|
|
#else
|
|
#include <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, then 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 final : public QMutex {
|
|
public:
|
|
Mutex() : QMutex(QMutex::Recursive) {}
|
|
|
|
private:
|
|
// not implemented
|
|
Mutex(const Mutex &);
|
|
Mutex &operator=(const Mutex &);
|
|
};
|
|
|
|
typedef QMutexLocker MutexLocker;
|
|
|
|
#endif
|
|
|
|
} // namespace TThread
|
|
|
|
//------------------------------------------------------------------------------
|
|
//------------------------------------------------------------------------------
|
|
|
|
#endif
|