'\param workq: Queue object to consume the work units from'

def __init__(self, workq, *args, **kwds):

    threading.Thread.__init__(self, *args, **kwds)
    self._workq = workq
    self.running = False
