caseOperator.py 文件源码

def multiple_run(self, rd_list, threadNum):
        # ??filename???????
        case_list = []
        for rd in rd_list:
            case_list.extend(rd.get_case_list())
        # ????
        divide = self.divide_case(len(case_list), threadNum)
        total_case = [case_list[i:i+divide] for i in range(0, len(case_list), divide)]
        # ??Operator???
        obj = run()
        # ??case_list???case
        threads = []
        for i in range(len(total_case)):
            threads.append(Thread(target=obj.run_case, args=(total_case[i], "thread_{}".format(i), result)))
        for t in threads:
            t.start()
        for t in threads:
            t.join()
        return self.deal_with_result(result)