schain Files · schainpy/model/graphics/jroplotter.py

Using threading.Lock in jroplotter.py

Miguel Valdez - - Load All Authors

File last commit:

r707:17810a6cdcd3


                r707:17810a6cdcd3

Download file

             jroplotter.py
        
                    136 lines
            
             | 3.2 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / schainpy / model / graphics / jroplotter.py
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

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

              r691
            
      '''

      Created on Jul 9, 2014

      @author: roj-idl71

      '''

      import os

      import datetime

      import numpy

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
      from time import sleep

      from Queue import Queue

        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
      from threading import Lock

      # from threading import Thread

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

              r691
            
        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
      from schainpy.model.proc.jroproc_base import Operation

      from schainpy.model.serializer.data import obj2Dict, dict2Obj

        Miguel Valdez
    
ImportError when msgpack is not installed

              r701
            
      from jroplot_correlation import *

      from jroplot_heispectra import *

      from jroplot_parameters import *

      from jroplot_spectra import *

      from jroplot_voltage import *

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
      class Plotter(Operation):

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

              r691
            
          isConfig = None

          name = None

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
          __queue = None

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

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

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
              Operation.__init__(self)

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

              r691
            
              self.isConfig = False

              self.name = plotter_name

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
              self.__queue = plotter_queue

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

              r691
            
          def getSubplots(self):

              nrow = self.nplots

              ncol = 1

              return nrow, ncol

          def setup(self, **kwargs):

              print "Initializing ..."

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
          def run(self, dataOut, id=None, **kwargs):

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

              r691
            
              """

              Input:

                  dataOut         :

                  id              :

              """

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
              packDict = {}

              packDict['id'] =  id

              packDict['name'] = self.name

              packDict['kwargs'] = kwargs

              packDict['data'] = obj2Dict(dataOut)

              self.__queue.put(packDict)

        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
      # class PlotManager(Thread):

      class PlotManager():

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
          __stop = False

          def __init__(self, plotter_queue):

        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
      #         Thread.__init__(self)

      #         self.setDaemon(True)

        Miguel Valdez
    
jroplotter.py updated

              r703
            
        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
              self.__queue = plotter_queue

        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
              self.__lock = Lock()

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
              self.plotInstanceDict = {}

              self.__stop = False

          def run(self):

        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
              if self.__queue.empty():

                  return

              self.__lock.acquire()

      #         if self.__queue.full():

      #             for i in range(int(self.__queue.qsize()/2)):

      #                 serial_data = self.__queue.get()

      #                 self.__queue.task_done()

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
              n = int(self.__queue.qsize()/3 + 1)

              for i in range(n):

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
                  serial_data = self.__queue.get()

                  self.__queue.task_done()

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
                  plot_id = serial_data['id']

                  plot_name = serial_data['name']

                  kwargs = serial_data['kwargs']

                  dataDict = serial_data['data']

                  dataPlot = dict2Obj(dataDict)

                  if plot_id not in self.plotInstanceDict.keys():

                      className = eval(plot_name)

                      self.plotInstanceDict[plot_id] = className()

                  plotter = self.plotInstanceDict[plot_id]

                  plotter.run(dataPlot, plot_id, **kwargs)

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

              r691
            
        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
              self.__lock.release()

        Miguel Valdez
    
SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain

              r698
            
          def stop(self):

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

              r691
            
        Miguel Valdez
    
Using threading.Lock in jroplotter.py

              r707
            
              self.__lock.acquire()

              self.__stop = True

              self.__lock.release()

          def close(self):

              self.__lock.acquire()

              for plot_id in self.plotInstanceDict.keys():

                  plotter = self.plotInstanceDict[plot_id]

                  plotter.close()

              self.__lock.release()

	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 A new Plotter Class was added for plotting using queues	r691	'''
		Created on Jul 9, 2014

		@author: roj-idl71
		'''
		import os
		import datetime
		import numpy

Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	from time import sleep
		from Queue import Queue
Miguel Valdez Using threading.Lock in jroplotter.py	r707	from threading import Lock
		# from threading import Thread
Miguel Valdez A new Plotter Class was added for plotting using queues	r691
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	from schainpy.model.proc.jroproc_base import Operation
		from schainpy.model.serializer.data import obj2Dict, dict2Obj
Miguel Valdez ImportError when msgpack is not installed	r701	from jroplot_correlation import *
		from jroplot_heispectra import *
		from jroplot_parameters import *
		from jroplot_spectra import *
		from jroplot_voltage import *

Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698
		class Plotter(Operation):
Miguel Valdez A new Plotter Class was added for plotting using queues	r691
		isConfig = None
		name = None
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	__queue = None
Miguel Valdez A new Plotter Class was added for plotting using queues	r691
		def __init__(self, plotter_name, plotter_queue=None):

Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	Operation.__init__(self)

Miguel Valdez A new Plotter Class was added for plotting using queues	r691	self.isConfig = False
		self.name = plotter_name
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	self.__queue = plotter_queue
Miguel Valdez A new Plotter Class was added for plotting using queues	r691
		def getSubplots(self):

		nrow = self.nplots
		ncol = 1
		return nrow, ncol

		def setup(self, **kwargs):

		print "Initializing ..."


Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	def run(self, dataOut, id=None, **kwargs):
Miguel Valdez A new Plotter Class was added for plotting using queues	r691
		"""

		Input:
		dataOut :
		id :
		"""

Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	packDict = {}

		packDict['id'] = id
		packDict['name'] = self.name
		packDict['kwargs'] = kwargs

		packDict['data'] = obj2Dict(dataOut)

		self.__queue.put(packDict)

Miguel Valdez Using threading.Lock in jroplotter.py	r707	# class PlotManager(Thread):
		class PlotManager():
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	__stop = False

		def __init__(self, plotter_queue):

Miguel Valdez Using threading.Lock in jroplotter.py	r707	# Thread.__init__(self)
		# self.setDaemon(True)
Miguel Valdez jroplotter.py updated	r703
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	self.__queue = plotter_queue
Miguel Valdez Using threading.Lock in jroplotter.py	r707	self.__lock = Lock()
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698
		self.plotInstanceDict = {}
		self.__stop = False

		def run(self):

Miguel Valdez Using threading.Lock in jroplotter.py	r707	if self.__queue.empty():
		return

		self.__lock.acquire()

		# if self.__queue.full():
		# for i in range(int(self.__queue.qsize()/2)):
		# serial_data = self.__queue.get()
		# self.__queue.task_done()
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698
Miguel Valdez Using threading.Lock in jroplotter.py	r707	n = int(self.__queue.qsize()/3 + 1)

		for i in range(n):
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698
Miguel Valdez Using threading.Lock in jroplotter.py	r707	serial_data = self.__queue.get()
		self.__queue.task_done()
Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698
		plot_id = serial_data['id']
		plot_name = serial_data['name']
		kwargs = serial_data['kwargs']
		dataDict = serial_data['data']

		dataPlot = dict2Obj(dataDict)

		if plot_id not in self.plotInstanceDict.keys():
		className = eval(plot_name)
		self.plotInstanceDict[plot_id] = className()

		plotter = self.plotInstanceDict[plot_id]
		plotter.run(dataPlot, plot_id, **kwargs)
Miguel Valdez A new Plotter Class was added for plotting using queues	r691
Miguel Valdez Using threading.Lock in jroplotter.py	r707

		self.__lock.release()

Miguel Valdez SChain v2.1.5: jroplotter.py and testPlotter.py were added to Signal Chain	r698	def stop(self):
Miguel Valdez A new Plotter Class was added for plotting using queues	r691
Miguel Valdez Using threading.Lock in jroplotter.py	r707	self.__lock.acquire()

		self.__stop = True

		self.__lock.release()

		def close(self):

		self.__lock.acquire()

		for plot_id in self.plotInstanceDict.keys():
		plotter = self.plotInstanceDict[plot_id]
		plotter.close()

		self.__lock.release()