如何在Python中并行地干净地循环两个文件

在Python中，您可以使用zip()函数和concurrent.futures库中的ThreadPoolExecutor来并行地循环两个文件。以下是一个示例代码：

import os
import concurrent.futures

def process_file(file_path):
    # 在这里处理文件
    pass

def process_files_in_parallel(files):
    with concurrent.futures.ThreadPoolExecutor() as executor:
        results = executor.map(process_file, files)

    return list(results)

if __name__ == "__main__":
    dir_path = "/path/to/your/directory"
    file_list = [os.path.join(dir_path, file) for file in os.listdir(dir_path)]
    process_files_in_parallel(file_list)

在这个示例中，我们首先导入os和concurrent.futures库。然后，我们定义一个process_file函数，该函数将在处理文件时执行。接下来，我们定义一个process_files_in_parallel函数，该函数接受一个文件列表，并使用ThreadPoolExecutor并行地处理它们。最后，我们在主函数中指定目录路径，并将其传递给process_files_in_parallel函数。

这个示例中的process_file函数只是一个占位符，您可以根据需要替换为您自己的文件处理逻辑。同时，您可以根据需要调整ThreadPoolExecutor的线程数量。