如何并行化一个程序来读写python中的大文件？

import multiprocessing
import os

def process_file(file_path):
    # 打开文件
    with open(file_path, 'r') as file:
        # 读取文件内容
        content = file.read()
        
        # 对文件内容进行处理（根据需求自定义）
        processed_content = process_content(content)
        
    # 将处理后的内容写入新文件
    new_file_path = get_new_file_path(file_path)
    with open(new_file_path, 'w') as new_file:
        new_file.write(processed_content)

def get_large_files(directory):
    large_files = []
    for root, dirs, files in os.walk(directory):
        for file in files:
            file_path = os.path.join(root, file)
            if os.path.getsize(file_path) > threshold_size:
                large_files.append(file_path)
    return large_files

if __name__ == '__main__':
    # 获取大文件路径列表
    large_files = get_large_files(directory)
    
    # 创建进程池
    pool = multiprocessing.Pool()
    
    # 并行处理大文件
    pool.map(process_file, large_files)
    
    # 关闭进程池
    pool.close()
    pool.join()