controller_api.py
140 lines
| 3.1 KiB
| text/x-python
|
PythonLexer
/ schainpy / controller_api.py
Miguel Valdez
|
r636 | import threading | |
| from PyQt4 import QtCore | |||
| from PyQt4.QtCore import SIGNAL | |||
| from schainpy.controller import Project | |||
| class ControllerThread(threading.Thread, Project): | |||
| def __init__(self, filename): | |||
| threading.Thread.__init__(self) | |||
| Project.__init__(self) | |||
| self.setDaemon(True) | |||
| self.filename = filename | |||
|
Miguel Valdez
|
r672 | ||
| self.lock = threading.Lock() | |||
|
Miguel Valdez
|
r636 | self.control = {'stop':False, 'pause':False} | |
| def __del__(self): | |||
| self.control['stop'] = True | |||
| def stop(self): | |||
|
Miguel Valdez
|
r672 | ||
| self.lock.acquire() | |||
|
Miguel Valdez
|
r636 | self.control['stop'] = True | |
|
Miguel Valdez
|
r672 | self.lock.release() | |
|
Miguel Valdez
|
r636 | def pause(self): | |
|
Miguel Valdez
|
r672 | ||
| self.lock.acquire() | |||
|
Miguel Valdez
|
r636 | self.control['pause'] = not(self.control['pause']) | |
|
Miguel Valdez
|
r672 | paused = self.control['pause'] | |
| self.lock.release() | |||
|
Miguel Valdez
|
r668 | ||
|
Miguel Valdez
|
r672 | return paused | |
|
Miguel Valdez
|
r668 | ||
|
Miguel Valdez
|
r672 | def isPaused(self): | |
|
Miguel Valdez
|
r636 | ||
|
Miguel Valdez
|
r672 | self.lock.acquire() | |
| paused = self.control['pause'] | |||
| self.lock.release() | |||
|
Miguel Valdez
|
r636 | ||
|
Miguel Valdez
|
r672 | return paused | |
| def isStopped(self): | |||
|
Miguel Valdez
|
r636 | ||
|
Miguel Valdez
|
r672 | self.lock.acquire() | |
| stopped = self.control['stop'] | |||
| self.lock.release() | |||
| return stopped | |||
|
Miguel Valdez
|
r636 | def run(self): | |
| self.control['stop'] = False | |||
| self.control['pause'] = False | |||
| self.readXml(self.filename) | |||
| self.createObjects() | |||
| self.connectObjects() | |||
| Project.run(self) | |||
| def isRunning(self): | |||
| return self.is_alive() | |||
| def isFinished(self): | |||
| return not self.is_alive() | |||
| class ControllerQThread(QtCore.QThread, Project): | |||
| def __init__(self, filename): | |||
| QtCore.QThread.__init__(self) | |||
| Project.__init__(self) | |||
| self.filename = filename | |||
|
Miguel Valdez
|
r672 | ||
| self.lock = threading.Lock() | |||
|
Miguel Valdez
|
r636 | self.control = {'stop':False, 'pause':False} | |
| def __del__(self): | |||
| self.control['stop'] = True | |||
| self.wait() | |||
| def stop(self): | |||
|
Miguel Valdez
|
r672 | ||
| self.lock.acquire() | |||
|
Miguel Valdez
|
r636 | self.control['stop'] = True | |
|
Miguel Valdez
|
r672 | self.lock.release() | |
|
Miguel Valdez
|
r636 | def pause(self): | |
|
Miguel Valdez
|
r672 | ||
| self.lock.acquire() | |||
|
Miguel Valdez
|
r636 | self.control['pause'] = not(self.control['pause']) | |
|
Miguel Valdez
|
r672 | paused = self.control['pause'] | |
| self.lock.release() | |||
| return paused | |||
| def isPaused(self): | |||
| self.lock.acquire() | |||
| paused = self.control['pause'] | |||
| self.lock.release() | |||
| return paused | |||
| def isStopped(self): | |||
| self.lock.acquire() | |||
| stopped = self.control['stop'] | |||
| self.lock.release() | |||
| return stopped | |||
|
Miguel Valdez
|
r636 | def run(self): | |
|
Miguel Valdez
|
r672 | ||
|
Miguel Valdez
|
r636 | self.control['stop'] = False | |
| self.control['pause'] = False | |||
| self.readXml(self.filename) | |||
| self.createObjects() | |||
| self.connectObjects() | |||
| self.emit( SIGNAL( "jobStarted( PyQt_PyObject )" ), 1) | |||
| Project.run(self) | |||
|
Miguel Valdez
|
r672 | self.emit( SIGNAL( "jobFinished( PyQt_PyObject )" ), 1) | |