diff --git a/api/db/services/file_service.py b/api/db/services/file_service.py
index 34776a6797..511624799f 100644
--- a/api/db/services/file_service.py
+++ b/api/db/services/file_service.py
@@ -562,8 +562,13 @@ class FileService(CommonService):
     @staticmethod
     def parse_docs(file_objs, user_id):
         with ThreadPoolExecutor(max_workers=12) as exe:
-            threads = [exe.submit(FileService.parse, file.filename, file.read(), False) for file in file_objs]
-            res = [th.result() for th in threads]
+            threads = []
+            for file in file_objs:
+                threads.append(exe.submit(FileService.parse, file.filename, file.read(), False))
+
+            res = []
+            for th in threads:
+                res.append(th.result())
 
         return "\n\n".join(res)
 
@@ -788,9 +793,9 @@ class FileService(CommonService):
         def image_to_base64(file):
             return "data:{};base64,{}".format(file["mime_type"],
                                         base64.b64encode(FileService.get_blob(file["created_by"], file["id"])).decode("utf-8"))
-        threads = []
-        imgs = []
         with ThreadPoolExecutor(max_workers=5) as exe:
+            threads = []
+            imgs = []
             for file in files:
                 if file["mime_type"].find("image") >=0:
                     if raw:
@@ -800,9 +805,7 @@ class FileService(CommonService):
                     continue
                 threads.append(exe.submit(FileService.parse, file["name"], FileService.get_blob(file["created_by"], file["id"]), True, file["created_by"], layout_recognize))
 
-            results = [th.result() for th in threads]
-
-        if raw:
-            return results, imgs
-        else:
-            return results
+            if raw:
+                return [th.result() for th in threads], imgs
+            else:
+                return [th.result() for th in threads]