#include "tthreadmessage.h"
#include "tthreadp.h"
#include <QThread>
 
QThread *MainThread = QThread::currentThread();
 
TThreadMessageDispatcher
    *Dispatcher;  // MUST BE CREATED  in the main thread!!!!!!
 
//------------------------------------------------------------------------------
 
bool TThread::isMainThread() { return MainThread == QThread::currentThread(); }
 
//------------------------------------------------------------------------------
 
TThreadMessageDispatcher::TThreadMessageDispatcher() {
  connect(this, SIGNAL(signaled(TThread::Message *)), this,
          SLOT(onSignal(TThread::Message *)));
  connect(this, SIGNAL(blockingSignaled(TThread::Message *)), this,
          SLOT(onSignal(TThread::Message *)), Qt::BlockingQueuedConnection);
}
 
//------------------------------------------------------------------------------
 
void TThreadMessageDispatcher::init() {
  if (!TThread::isMainThread()) return;
  if (Dispatcher == 0) Dispatcher = new TThreadMessageDispatcher();
}
 
//------------------------------------------------------------------------------
 
TThreadMessageDispatcher *TThreadMessageDispatcher::instance() {
  assert(Dispatcher);
  return Dispatcher;
}
 
//------------------------------------------------------------------------------
 
void TThreadMessageDispatcher::emitSignaled(TThread::Message *msg) {
  Q_EMIT signaled(msg);
}
 
//------------------------------------------------------------------------------
 
void TThreadMessageDispatcher::emitBlockingSignaled(TThread::Message *msg) {
  Q_EMIT blockingSignaled(msg);
}
 
//------------------------------------------------------------------------------
 
void TThreadMessageDispatcher::onSignal(TThread::Message *msg) {
  msg->onDeliver();
  delete msg;
}
 
//------------------------------------------------------------------------------
 
TThread::Message::Message() {}
 
//------------------------------------------------------------------------------
void TThread::Message::send() {
  if (isMainThread())
    onDeliver();
  else
    TThreadMessageDispatcher::instance()->emitSignaled(clone());
}
 
//------------------------------------------------------------------------------
 
void TThread::Message::sendBlocking() {
  if (isMainThread())
    onDeliver();
  else
    TThreadMessageDispatcher::instance()->emitBlockingSignaled(clone());
}
 
//------------------------------------------------------------------------------