ab.ThreadRunner Class Reference

Public Member Functions
def	__init__ (self, args)
def	add (self, args, fn)
def	wait (self)

Public Attributes
	concise
	threads

Detailed Description

Simplest and stupidiest threaded executer.

Definition at line 145 of file ab.py.

Constructor & Destructor Documentation

__init__()

def ab.ThreadRunner.__init__	(		self,
			args
	)

Definition at line 147 of file ab.py.

  def __init__(self, args):
    self.concise = args.concise
    self.threads = []
 

Member Function Documentation

add()

def ab.ThreadRunner.add	(		self,
			args,
			fn
	)

Definition at line 151 of file ab.py.

  def add(self, args, fn):
    if len(self.threads) >= args.threads:
      self.wait()
    t = ThreadWithException(target = fn)
    t.daemon = True
    self.threads.append(t)
    t.start()
 

wait()

def ab.ThreadRunner.wait

(

self

)

Definition at line 159 of file ab.py.

  def wait(self):
    def spin():
      i = 0
      spinners = [".  ", ".. ", "..."]
      while len(self.threads) > 0:
        timesLock.acquire()
        sys.stderr.write(
            "\r" + spinners[i % len(spinners)] +
            " (%d threads running)" % len(self.threads) +
            "           \r" # spaces for erasing characters
        )
        timesLock.release()
        time.sleep(0.5)
        i += 1
 
    if not self.concise:
      ts = Thread(target = spin);
      ts.start()
 
    for t in self.threads:
      t.join()
 
    exceptions = []
    for t in self.threads:
      if t.exception:
        exceptions.append(t.exception)
 
    self.threads = []
 
    if not self.concise:
      ts.join()
 
    if len(exceptions):
      for exc in exceptions:
        print(exc)
      raise exceptions[0]
 
 

Member Data Documentation

concise

ab.ThreadRunner.concise

Definition at line 148 of file ab.py.

threads

ab.ThreadRunner.threads

Definition at line 149 of file ab.py.

---

The documentation for this class was generated from the following file:

• third_party/skia/tools/calmbench/ab.py