1 // Copyright (C) 2007-2008 CEA/DEN, EDF R&D, OPEN CASCADE
3 // Copyright (C) 2003-2007 OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 // CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
6 // This library is free software; you can redistribute it and/or
7 // modify it under the terms of the GNU Lesser General Public
8 // License as published by the Free Software Foundation; either
9 // version 2.1 of the License.
11 // This library is distributed in the hope that it will be useful,
12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 // Lesser General Public License for more details.
16 // You should have received a copy of the GNU Lesser General Public
17 // License along with this library; if not, write to the Free Software
18 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
20 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
22 // File : PyInterp_Dispatcher.cxx
23 // Author : Sergey ANIKIN, OCC
26 #include "PyInterp_Dispatcher.h" // !!! WARNING !!! THIS INCLUDE MUST BE THE VERY FIRST !!!
27 #include "PyInterp_Interp.h"
28 #include "PyInterp_Watcher.h"
29 #include <SALOME_Event.h>
32 #include <QCoreApplication>
34 class PyInterp_ExecuteEvent: public SALOME_Event
37 PyInterp_Request* myRequest;
38 PyInterp_ExecuteEvent( PyInterp_Request* r )
40 virtual void Execute()
48 PyInterp_Dispatcher* PyInterp_Dispatcher::myInstance = 0;
50 void PyInterp_Request::process()
54 bool isSync = IsSync();
60 processEvent( listener() );
66 void PyInterp_Request::safeExecute()
68 //ProcessVoidEvent( new PyInterp_ExecuteEvent( this ) );
72 void PyInterp_Request::Destroy( PyInterp_Request* request )
74 // Lock and unlock the mutex to avoid errors on its deletion
75 request->myMutex.lock();
76 request->myMutex.unlock();
80 QEvent* PyInterp_Request::createEvent() const
82 return new PyInterp_Event( PyInterp_Event::ES_NOTIFY, (PyInterp_Request*)this );
85 void PyInterp_Request::processEvent( QObject* o )
90 QEvent* e = createEvent();
95 QCoreApplication::postEvent( o, e );
98 QCoreApplication::sendEvent( o, e );
103 void PyInterp_Request::setListener( QObject* o )
110 void PyInterp_LockRequest::safeExecute()
113 PyLockWrapper aLock = getInterp()->GetLockWrapper();
114 //ProcessVoidEvent( new PyInterp_ExecuteEvent( this ) );
119 PyInterp_Event::~PyInterp_Event()
121 PyInterp_Request::Destroy( myRequest );
125 PyInterp_Dispatcher* PyInterp_Dispatcher::Get()
128 myInstance = new PyInterp_Dispatcher();
132 PyInterp_Dispatcher::PyInterp_Dispatcher()
135 myWatcher = new PyInterp_Watcher();
138 PyInterp_Dispatcher::~PyInterp_Dispatcher()
140 // Clear the request queue
143 QListIterator<RequestPtr> it( myQueue );
144 while ( it.hasNext() )
145 PyInterp_Request::Destroy( it.next() );
148 myQueueMutex.unlock();
150 // Wait for run() to finish
157 bool PyInterp_Dispatcher::IsBusy() const
162 void PyInterp_Dispatcher::Exec( PyInterp_Request* theRequest )
167 //if ( theRequest->IsSync() && !IsBusy() ) // synchronous processing - nothing is done if dispatcher is busy!
168 if ( theRequest->IsSync() ) // synchronous processing - nothing is done if dispatcher is busy!
169 processRequest( theRequest );
170 else // asynchronous processing
173 myQueue.enqueue( theRequest );
174 if ( theRequest->listener() )
175 QObject::connect( theRequest->listener(), SIGNAL( destroyed( QObject* ) ), myWatcher, SLOT( onDestroyed( QObject* ) ) );
176 myQueueMutex.unlock();
183 void PyInterp_Dispatcher::run()
185 // MESSAGE("*** PyInterp_Dispatcher::run(): STARTED")
186 PyInterp_Request* aRequest;
188 // prepare for queue size check
191 while( myQueue.size() ) {
192 // MESSAGE("*** PyInterp_Dispatcher::run(): next request taken from the queue")
193 aRequest = myQueue.head();
195 // let other threads append their requests to the end of the queue
196 myQueueMutex.unlock();
198 // processRequest() may delete a request, so this pointer must not be used
199 // after request is processed!
200 processRequest( aRequest );
202 // prepare for removal of the first request in the queue
204 // IMPORTANT: the first item could have been removed by objectDestroyed() --> we have to check it
205 if ( myQueue.head() == aRequest ) // It's still here --> remove it
208 // MESSAGE("*** PyInterp_Dispatcher::run(): request processed")
211 myQueueMutex.unlock();
212 // MESSAGE("*** PyInterp_Dispatcher::run(): FINISHED")
215 void PyInterp_Dispatcher::processRequest( PyInterp_Request* theRequest )
217 theRequest->process();
220 void PyInterp_Dispatcher::objectDestroyed( const QObject* o )
222 // prepare for modification of the queue
225 QMutableListIterator<RequestPtr> it( myQueue );
226 while ( it.hasNext() )
228 RequestPtr r = it.next();
229 if ( o == r->listener() )
231 r->setListener( 0 ); // to prevent event posting
236 myQueueMutex.unlock();