#pragma once

#ifndef TTHREADP_H
#define TTHREADP_H

#include <QObject>

#include "tthreadmessage.h"

//=====================================================================

//======================================
//    TThreadMessageDispatcher class
//--------------------------------------

// NOTE: This class should eventually be moved to tthreadmessagep.h...
class TThreadMessageDispatcher final : public QObject  // singleton
{
  Q_OBJECT

public:
  TThreadMessageDispatcher();
Q_SIGNALS:
  void signaled(TThread::Message *msg);
  void blockingSignaled(TThread::Message *msg);
protected Q_SLOTS:
  void onSignal(TThread::Message *msg);

public:
  void emitSignaled(TThread::Message *msg);
  void emitBlockingSignaled(TThread::Message *msg);
  static void init();
  static TThreadMessageDispatcher *instance();
};

//=====================================================================

namespace TThread {
// Forward declarations
class ExecutorId;
class ExecutorImpSlots;
}

//=====================================================================

//==============================
//    ExecutorImpSlots class
//------------------------------

class TThread::ExecutorImpSlots final : public QObject {
  Q_OBJECT

public:
  ExecutorImpSlots();
  ~ExecutorImpSlots();

  // The following is provided to ensure that point #3 in Qt reference in page
  // "Thread support in Qt"
  // is satisfied:

  //      "You must ensure that all objects created in
  //        a thread are deleted before you delete the QThread."

  // So, specifically, thread creation should happen only in the main thread,
  // not in worker threads.
  void emitRefreshAssignments();

Q_SIGNALS:
  void refreshAssignments();

public Q_SLOTS:
  void onTerminated();
  void onRefreshAssignments();
};

#endif