有我正在用某种功能一一处理的文件列表:
list_of_files = [file_1, file_2, file_3, .... file_n]
# each file we are processing in function function_x(file)
for file in list_of_files:
function_x(file)
Run Code Online (Sandbox Code Playgroud)
但处理一个文件需要太长时间,所以我想并行处理 4 个文件,当其中任何一个文件完成后,继续下一个表单 list_of_files
尝试使用并行映射:
import multiprocessing
pool = multiprocessing.Pool()
pool.map(function_x, list_of_files)
Run Code Online (Sandbox Code Playgroud)