在Python中对包含" for“循环的已定义函数应用"for”循环的并行处理

import threading

def process_data(data):
    # 包含"for"循环的已定义函数
    for item in data:
        # 执行任务

def parallel_processing(data, num_threads):
    # 创建多个线程对象
    threads = []
    for i in range(num_threads):
        t = threading.Thread(target=process_data, args=(data,))
        threads.append(t)

    # 启动线程
    for t in threads:
        t.start()

    # 等待所有线程执行完毕
    for t in threads:
        t.join()

# 调用并行处理函数
data = [1, 2, 3, 4, 5]
num_threads = 2
parallel_processing(data, num_threads)

import multiprocessing

def process_data(data):
    # 包含"for"循环的已定义函数
    for item in data:
        # 执行任务

def parallel_processing(data, num_processes):
    # 创建多个进程对象
    processes = []
    for i in range(num_processes):
        p = multiprocessing.Process(target=process_data, args=(data,))
        processes.append(p)

    # 启动进程
    for p in processes:
        p.start()

    # 等待所有进程执行完毕
    for p in processes:
        p.join()

# 调用并行处理函数
data = [1, 2, 3, 4, 5]
num_processes = 2
parallel_processing(data, num_processes)