import threading
from Queue import Queue

from schainpy.controller import Project
from schainpy.model.graphics.jroplotter import PlotManager

class ControllerThread(threading.Thread, Project):
    
    def __init__(self, plotter_queue=None):
        
        threading.Thread.__init__(self)
        Project.__init__(self, plotter_queue)
        
        self.setDaemon(True)
        
        self.lock = threading.Lock()
        self.control = {'stop':False, 'pause':False}
    
    def __del__(self):
        
        self.control['stop'] = True
    
    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.writeXml()
        
        self.createObjects()
        self.connectObjects()
        Project.run(self)
        
    def isRunning(self):
        
        return self.is_alive()
    
    def isFinished(self):
        
        return not self.is_alive()

    def setPlotters(self):
        
        plotterList = PlotManager.plotterList
        
        for thisPUConfObj in self.procUnitConfObjDict.values():
            
            inputId = thisPUConfObj.getInputId()
            
            if int(inputId) == 0:
                continue
            
            for thisOpObj in thisPUConfObj.getOperationObjList():
                
                if thisOpObj.type == "self":
                    continue
                
                if thisOpObj.name in plotterList:
                    thisOpObj.type = "plotter"

    def setPlotterQueue(self, plotter_queue):
        
        self.plotterQueue = plotter_queue
        
    def getPlotterQueue(self):
        
        return self.plotterQueue

    def useExternalPlotter(self):
        
        self.plotterQueue = Queue(10)
        self.setPlotters()
        
        plotManagerObj = PlotManager(self.plotterQueue)
        plotManagerObj.setController(self)
        
        return plotManagerObj
                    
# 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)
#