diff --git a/flask_app/routes/test_preprocess.py b/flask_app/routes/test_preprocess.py index 04c8990..f6a105f 100644 --- a/flask_app/routes/test_preprocess.py +++ b/flask_app/routes/test_preprocess.py @@ -1,3 +1,4 @@ +import multiprocessing import os from flask import request, jsonify, Blueprint, g @@ -30,12 +31,9 @@ def process_file(): # print(file_path) # 调用预处理函数 start_time = time.time() - result = preprocess_files( - output_folder=output_folder, - file_path=file_path, - file_type=file_type, - logger=logger - ) + with multiprocessing.Pool(processes=1) as pool: + # 调用 apply 或 apply_async 执行子进程任务 + result = pool.apply(preprocess_files, args=(output_folder, file_path, 2, logger,)) # 处理结果 if not result: