replyblock.h

/*
*
* $LastChangedDate: $
*   $LastChangedBy: $
*        $Revision: $
*          $Author: $
*             $URL: $
*              $Id: $
*           edc@vremsoft.com
*
*
*             *** 2014<c> ***
*
*
*/
 
#pragma once
 
 
#include <QtCore>
#include <QVariantList>
#include <vremthread.h>
#include <platform_global.h>
 
 
 
 
 
 
class PLATFORMSHARED_EXPORT ReplyBlock : public VremThread
{
public :
  struct TQUE {
    int Command;
    QVariantList UserData;
    TQUE( int command) : Command(command) {}
  };
 
 
 typedef QList<TQUE> VQVVArrayVArray;
 
private :
  typedef QMap<int, TQUE> MapTMS;
  typedef MapTMS::iterator    MapTMSItr;
 
  QMutex memLock;
 
  QWaitCondition enqueue;
 
  VQVVArrayVArray queue;
 
  QMutex tmsLock;
  MapTMS tmsQueue;
 
protected :
 
  void timerEvent(QTimerEvent *event);
 
public:
 
  ReplyBlock( QThread::Priority priority=QThread::LowPriority,
    QObject *parent = 0);
 
  virtual ~ReplyBlock();
 
  void run();
 
  void ProcessThis(TQUE cmd, int mseconds = 0);
 
  void ProcessThis(int cmd, int mseconds = 0);
 
  virtual void UserProcess(TQUE &)  { }
 
  virtual void WakeMeUp(void);
 
};