worker.py 文件源码

def __init__(self, workdir, n_threads=0):
        self.n_threads = cpu_count() if n_threads == 0 else n_threads
        self.process_list = []
        self.workdir = workdir

        self.work_queue = Queue()
        self.update_queues = []
        self.testcase_report = Queue()

        self.coverage = {}
        self.testcases = []
        self.executed_testcases = Value('i', 0)

        self.mutator = mutator()

        if not os.path.exists(workdir):
            os.makedirs(workdir)
        os.chdir(workdir)