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 184 of file psClasses.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 185 of file psClasses.py.

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

Member Function Documentation

append()

def psClasses.queueNode.append	(		self,
			item
	)

Definition at line 190 of file psClasses.py.

References psClasses.queueNode.RunningThreads, and psClasses.queueNode.ThreadLog.

Referenced by diclist.diclist.add().

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

pendingThreads()

def psClasses.queueNode.pendingThreads

(

self

)

Definition at line 195 of file psClasses.py.

References psClasses.queueNode.RunningThreads.

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

queueWeight()

def psClasses.queueNode.queueWeight

(

self

)

Definition at line 198 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

QueueSem

psClasses.queueNode.QueueSem

Definition at line 186 of file psClasses.py.

RunningThreads

psClasses.queueNode.RunningThreads

Definition at line 187 of file psClasses.py.

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

ThreadLog

psClasses.queueNode.ThreadLog

Definition at line 188 of file psClasses.py.

Referenced by psClasses.queueNode.append().