schain-jc Files · schainpy/controller_api.py

Using threading.Lock in jroplotter.py

Miguel Valdez - - Load All Authors

File last commit:

r695:33996c3ce4a6


                r707:17810a6cdcd3

Download file

             controller_api.py
        
                    140 lines
            
             | 3.2 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / schainpy / controller_api.py
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
      import threading

      from schainpy.controller import Project

      class ControllerThread(threading.Thread, Project):

        Miguel Valdez
    
A new Plotter Class was added for plotting using queues

              r691
            
          def __init__(self, filename=None, plotter_queue=None):

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
              threading.Thread.__init__(self)

        Miguel Valdez
    
A new Plotter Class was added for plotting using queues

              r691
            
              Project.__init__(self, filename, plotter_queue)

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
              self.setDaemon(True)

        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              self.lock = threading.Lock()

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
              self.control = {'stop':False, 'pause':False}

          def __del__(self):

              self.control['stop'] = True

          def stop(self):

        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              self.lock.acquire()

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
              self.control['stop'] = True

        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              self.lock.release()

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
          def pause(self):

        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              self.lock.acquire()

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
              self.control['pause'] = not(self.control['pause'])

        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              paused = self.control['pause']

              self.lock.release()

        Miguel Valdez
    
GUI: Every icon were resized

              r668
            
        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              return paused

        Miguel Valdez
    
GUI: Every icon were resized

              r668
            
        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
          def isPaused(self):

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              self.lock.acquire()

              paused = self.control['pause']

              self.lock.release()

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              return paused

          def isStopped(self):

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
        Miguel Valdez
    
Version: 2.1.3.2...

              r672
            
              self.lock.acquire()

              stopped = self.control['stop']

              self.lock.release()

              return stopped

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
          def run(self):

              self.control['stop'] = False

              self.control['pause'] = False

        Miguel Valdez
    
Bug fixed in controller_api.py: reading xml file but not writing

              r695
            
              if not self.writeXml(self.filename):

                  return 

        Miguel Valdez
    
ControllerThread was eliminated from controller.py and it was added to controller_api.py

              r636
            
              self.createObjects()

              self.connectObjects()

              Project.run(self)

          def isRunning(self):

              return self.is_alive()

          def isFinished(self):

              return not self.is_alive()

        Miguel Valdez
    
              r681
            
      # from PyQt4 import QtCore

      # from PyQt4.QtCore import SIGNAL

      # 

      # class ControllerQThread(QtCore.QThread, Project):

      #     

      #     def __init__(self, filename):

      #         

      #         QtCore.QThread.__init__(self)

      #         Project.__init__(self)

      #         

      #         self.filename = filename

      #         

      #         self.lock = threading.Lock()

      #         self.control = {'stop':False, 'pause':False}

      #     

      #     def __del__(self):

      #         

      #         self.control['stop'] = True

      #         self.wait()

      #         

      #     def stop(self):

      #         

      #         self.lock.acquire()

      #         

      #         self.control['stop'] = True

      #         

      #         self.lock.release()

      #         

      #     def pause(self):

      #         

      #         self.lock.acquire()

      #         

      #         self.control['pause'] = not(self.control['pause'])

      #         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

      #     

      #     def run(self):

      #         

      #         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)

      #         self.emit( SIGNAL( "jobFinished( PyQt_PyObject )" ), 1)

      #

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636	import threading

		from schainpy.controller import Project

		class ControllerThread(threading.Thread, Project):

Miguel Valdez A new Plotter Class was added for plotting using queues	r691	def __init__(self, filename=None, plotter_queue=None):
Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636
		threading.Thread.__init__(self)
Miguel Valdez A new Plotter Class was added for plotting using queues	r691	Project.__init__(self, filename, plotter_queue)
Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636
		self.setDaemon(True)

Miguel Valdez Version: 2.1.3.2...	r672	self.lock = threading.Lock()
Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636	self.control = {'stop':False, 'pause':False}

		def __del__(self):

		self.control['stop'] = True

		def stop(self):
Miguel Valdez Version: 2.1.3.2...	r672
		self.lock.acquire()

Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636	self.control['stop'] = True

Miguel Valdez Version: 2.1.3.2...	r672	self.lock.release()

Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636	def pause(self):
Miguel Valdez Version: 2.1.3.2...	r672
		self.lock.acquire()

Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636	self.control['pause'] = not(self.control['pause'])
Miguel Valdez Version: 2.1.3.2...	r672	paused = self.control['pause']

		self.lock.release()
Miguel Valdez GUI: Every icon were resized	r668
Miguel Valdez Version: 2.1.3.2...	r672	return paused
Miguel Valdez GUI: Every icon were resized	r668
Miguel Valdez Version: 2.1.3.2...	r672	def isPaused(self):
Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636
Miguel Valdez Version: 2.1.3.2...	r672	self.lock.acquire()
		paused = self.control['pause']
		self.lock.release()
Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636
Miguel Valdez Version: 2.1.3.2...	r672	return paused

		def isStopped(self):
Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636
Miguel Valdez Version: 2.1.3.2...	r672	self.lock.acquire()
		stopped = self.control['stop']
		self.lock.release()

		return stopped

Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636	def run(self):
		self.control['stop'] = False
		self.control['pause'] = False

Miguel Valdez Bug fixed in controller_api.py: reading xml file but not writing	r695	if not self.writeXml(self.filename):
		return

Miguel Valdez ControllerThread was eliminated from controller.py and it was added to controller_api.py	r636	self.createObjects()
		self.connectObjects()
		Project.run(self)

		def isRunning(self):

		return self.is_alive()

		def isFinished(self):

		return not self.is_alive()
Miguel Valdez	r681
		# from PyQt4 import QtCore
		# from PyQt4.QtCore import SIGNAL
		#
		# class ControllerQThread(QtCore.QThread, Project):
		#
		# def __init__(self, filename):
		#
		# QtCore.QThread.__init__(self)
		# Project.__init__(self)
		#
		# self.filename = filename
		#
		# self.lock = threading.Lock()
		# self.control = {'stop':False, 'pause':False}
		#
		# def __del__(self):
		#
		# self.control['stop'] = True
		# self.wait()
		#
		# def stop(self):
		#
		# self.lock.acquire()
		#
		# self.control['stop'] = True
		#
		# self.lock.release()
		#
		# def pause(self):
		#
		# self.lock.acquire()
		#
		# self.control['pause'] = not(self.control['pause'])
		# 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
		#
		# def run(self):
		#
		# 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)
		# self.emit( SIGNAL( "jobFinished( PyQt_PyObject )" ), 1)
		#