### Python多线程读取文件夹内所有CSV文件并以字典形式返回结果 在Python中，可以使用`threading`模块来实现多线程操作。为了读取文件夹内的所有CSV文件，并将每个文件的读取结果以字典的形式返回，可以结合`pandas`库进行数据处理。以下是一个完整的解决方案[^3]。 #### 代码实现 ```python import os import pandas as pd import threading def read_csv(file_path): """读取单个CSV文件""" try: data = pd.read_csv(file_path) return data except Exception as e: print(f"Error reading {file_path}: {e}") return None def worker(file_path, results, index): """多线程任务函数""" results[index] = read_csv(file_path) def read_all_csvs_in_folder(folder_path): """使用多线程读取文件夹内所有CSV文件""" # 获取文件夹内所有CSV文件路径 csv_files = [os.path.join(folder_path, f) for f in os.listdir(folder_path) if f.endswith('.csv')] # 创建一个线程安全的字典用于存储结果 results = {} # 创建线程列表 threads = [] for i, file_path in enumerate(csv_files): thread = threading.Thread(target=worker, args=(file_path, results, i)) threads.append(thread) thread.start() # 等待所有线程完成 for thread in threads: thread.join() # 将结果按文件名组织成字典 final_results = {os.path.basename(path): results[i] for i, path in enumerate(csv_files)} return final_results # 示例调用 folder_path = "./csv_files" # 替换为实际文件夹路径 results = read_all_csvs_in_folder(folder_path) for file_name, data in results.items(): print(f"{file_name} has shape {data.shape if data is not None else 'Error'}") ``` #### 代码说明 1. **`read_csv`函数**：负责读取单个CSV文件。如果读取失败，会打印错误信息并返回`None`。 2. **`worker`函数**：作为线程的任务函数，负责调用`read_csv`并将结果存入共享字典。 3. **`read_all_csvs_in_folder`函数**：遍历指定文件夹中的所有CSV文件，创建线程并启动它们。最后将结果整理为以文件名为键、数据框为值的字典[^3]。 #### 注意事项 - 在多线程环境中，确保对共享资源（如字典）的操作是线程安全的。上述代码中，由于每个线程只写入字典的一个独立位置，因此无需额外的锁机制。 - 如果文件数量较多或文件较大，可能需要考虑线程池或异步I/O以提高性能[^4]。