/* UTF-8 encoded file !!!!*/#ifndef T_RETURNSYNCOBJECT_H#define T_RETURNSYNCOBJECT_H#include <QObject>#include <QMutexLocker>#include <QVariant>/*@Denjs 2010Public Domain licensed ("Общественное достояние")QT 4.6 tested*//*Класс презназначенный для реализациисинхронного взаимодействиячерез сигнал-слоты.Может использоваться для передачи параметров расчетов обратно к вызывающей стороне,для подтверждения получения сигнала.Может приостановить исходный поток до момента пока сигнал не будет обработан.Экземпляр класса передается с сигналом,а на приемной стороне вызывается методbool t_returnSyncObject::done()для сигнализации того, что обработка закончена.для отслеживания случая, когда сигнал подключенк более чем 1 слоту, вызываетсяbool t_returnSyncObject::done()На исходной стороне, после испускания сигнала,вызываетсяbool t_returnSyncObject::waitForDone(int timeOut);метод задерживает управление до момента,пока не вызван .done() или истечения таймаута.Для передачи параметров используетсяt_returnSyncObject::set_result(QVariant retult)*/class t_returnSyncObject : public QObject{ Q_OBJECTpublic: explicit t_returnSyncObject(QObject *parent = 0);signals:public slots: bool done(); bool isDone(); bool reset(); bool waitForDone(int _timeOut); bool setResult(QVariant __result); QVariant result();private: mutable QMutex mutex; bool _done; QVariant _result;};//================================================================================//--------------------------------------------------------------------------------// Linux :#if defined (Q_WS_X11) /* nothing needs to be included here yet...*/// Win :#elif defined (Q_WS_WIN) // for Sleep() : #include <windows.h>// Mac:#elif defined (Q_WS_MAC) /* NOT SUPPORTED THIS VERSION */#else /* NOT SUPPORTED THIS VERSION */#endif//--------------------------------------------------------------------------------static void SleepMS_qt( unsigned int time){ // Linux: #if defined (Q_WS_X11) usleep(time*1000);//sleep in millisecinds // Win: #elif defined (Q_WS_WIN) Sleep(time);//WIN 2008.02.19 // Mac: #elif defined (Q_WS_MAC) // NOT SUPPORTED THIS VERSION #else // NOT SUPPORTED THIS VERSION #endif return;};#endif // T_RETURNSYNCOBJECT_H
/* UTF-8 encoded file !!!!*/#include "t_returnSyncObject.h"//============================================================================t_returnSyncObject::t_returnSyncObject(QObject *parent) : QObject(parent) { reset(); };//============================================================================bool t_returnSyncObject::done() { QMutexLocker locker(&mutex); _done=true; return _done; };//============================================================================bool t_returnSyncObject::isDone() { QMutexLocker locker(&mutex); return _done; };//============================================================================bool t_returnSyncObject::waitForDone(int _timeOut) { int timePassed=0; int stepTimeout=200; if ( (!isDone()) && (timePassed<_timeOut) ) { SleepMS_qt(stepTimeout); //sleep timePassed += stepTimeout; }; return isDone(); };//============================================================================bool t_returnSyncObject::setResult(QVariant __result) { QMutexLocker locker(&mutex); _result = __result; return _done; };//============================================================================QVariant t_returnSyncObject::result() { return _result; };//============================================================================bool t_returnSyncObject::reset() { QMutexLocker locker(&mutex); _result = QVariant(); _done = false; return true; };
t_returnSyncObject *syncResultObject=new t_returnSyncObject(this); emit mySignal(syncResultObject); bool rez=syncResultObject->waitForDone(5000);// ждем не более 5 секунд if (rez==false) //таймаут... { qDebug() << "Таймаут получения ответа от приемной стороны.."; return -1; }; //теперь проверим что нам ответил слот-сервис QString rezStr=syncResultObject->result().toString();
void myClass2::mySlot(t_returnSyncObject *syncResultObject){ if (syncResultObject==0) return; if (syncResultObject->isDone()) return; QString rez="Обработано!"; syncResultObject->setResult(QVariant(rez)); syncResultObject->done(); return;}
C++ (Qt)#include <QThread> class QThreadHack : public QThread{public: using QThread::sleep; using QThread::msleep; using QThread::usleep;}; ...// usingQThreadHack::msleep(5000);
