(self, file_path)
| 154 | self.mutex = threading.Lock() # 线程锁,访问全局变量时需要上锁 |
| 155 | |
| 156 | def __scan_file_callback__(self, file_path): |
| 157 | file_result = CpplintRunner().run_cpplint_on_file( |
| 158 | file_path, self.cmd_args, self.regex_client, self.source_dir, self.rules |
| 159 | ) |
| 160 | self.mutex.acquire() # 上锁 |
| 161 | self.issues.extend(file_result) |
| 162 | self.mutex.release() # 解锁 |
| 163 | |
| 164 | def run(self, file_paths): |
| 165 | callback_queue = CallbackQueue(min_threads=20, max_threads=1000) |
nothing calls this directly
no test coverage detected