带循环的多df

import pandas as pd
from concurrent.futures import ThreadPoolExecutor

# 示例数据框列表
dataframes = [pd.DataFrame({'A': range(1000)}), pd.DataFrame({'A': range(2000)})]

def process_df(df):
    # 模拟数据处理操作
    return df.mean()

with ThreadPoolExecutor() as executor:
    results = list(executor.map(process_df, dataframes))

print(results)

import pandas as pd
import threading

# 示例数据框列表
dataframes = [pd.DataFrame({'A': range(1000)}), pd.DataFrame({'A': range(2000)})]

lock = threading.Lock()

def process_df(df):
    # 模拟数据处理操作
    result = df.mean()
    with lock:
        # 保护共享资源
        print(result)

threads = []
for df in dataframes:
    thread = threading.Thread(target=process_df, args=(df,))
    threads.append(thread)
    thread.start()

for thread in threads:
    thread.join()