job.py 文件源码

def __init__(self, work_queue=None):
        _th.Thread.__init__(self)
        self.ev = _th._Event()
        self._event_status = False;  # ????
        self.var_lock = True;
        self.work_queue = work_queue
        self.mutex = _th.Lock()  # ???
        self.start();