如何在python中并行压缩文件

import os
import zipfile
import concurrent.futures

def compress_file(file_path):
    with zipfile.ZipFile(file_path + '.zip', 'w', compression=zipfile.ZIP_DEFLATED) as zipf:
        zipf.write(file_path, os.path.basename(file_path))
    os.remove(file_path)  # 可选，压缩后删除原文件

files_to_compress = []
directory = '/path/to/files'
for root, dirs, files in os.walk(directory):
    for file in files:
        file_path = os.path.join(root, file)
        files_to_compress.append(file_path)

with concurrent.futures.ThreadPoolExecutor() as executor:
    executor.map(compress_file, files_to_compress)