psClasses.queueNode Class Reference

Public Member Functions
def	__init__ (self, cores=4, jay=2)
def	append (self, item)
def	pendingThreads (self)
def	queueWeight (self)

Public Attributes
	QueueSem
	RunningThreads
	ThreadLog

Detailed Description

Definition at line 183 of file psClasses.py.

Constructor & Destructor Documentation

def psClasses.queueNode.__init__	(		self,
			cores = 4,
			jay = 2
	)

Definition at line 184 of file psClasses.py.

  def __init__(self,cores = 4,jay = 2):
    self.QueueSem = BoundedSemaphore(value=cores/jay)
    self.RunningThreads = []
    self.ThreadLog = []
  

Member Function Documentation

def psClasses.queueNode.append	(		self,
			item
	)

Definition at line 189 of file psClasses.py.

Referenced by diclist.diclist.add(), and Vispa.Views.PropertyView.PropertyView.addProperty().

  def append(self,item):
    self.RunningThreads.append(item)
    t=time.time()
    self.ThreadLog.append([t,item.BuildNode.LibName,"INFO: %s thread %s added for Library %s" % (t,item.name,item.BuildNode.LibName)])    
  

def psClasses.queueNode.pendingThreads

(

self

)

Definition at line 194 of file psClasses.py.

References psClasses.queueNode.RunningThreads.

  def pendingThreads(self):
    return len([x for x in self.RunningThreads if x.is_alive()])
    

def psClasses.queueNode.queueWeight

(

self

)

Definition at line 197 of file psClasses.py.

References psClasses.queueNode.RunningThreads.

  def queueWeight(self):
    return sum([x.Weight for x in self.RunningThreads if x.is_alive()])
  
  
     

Member Data Documentation

psClasses.queueNode.QueueSem

Definition at line 185 of file psClasses.py.

psClasses.queueNode.RunningThreads

Definition at line 186 of file psClasses.py.

Referenced by psClasses.queueNode.pendingThreads(), and psClasses.queueNode.queueWeight().

psClasses.queueNode.ThreadLog

Definition at line 187 of file psClasses.py.