jack 3 months ago
parent
commit
1f47f39430
1 changed files with 6 additions and 2 deletions
  1. 6 2
      app/libs/thread_executor.py

+ 6 - 2
app/libs/thread_executor.py

@@ -53,7 +53,7 @@ def run_with_executor(executor: Executor, func, tasks: List, timeout: int):
             results.append(future.result())
     return results
     """
-
+    """
     results = []
     # Iterate over tasks and execute them sequentially
     for task in tasks:
@@ -67,7 +67,7 @@ def run_with_executor(executor: Executor, func, tasks: List, timeout: int):
 
     return results
 
-    """
+
     futures = [executor.submit(lambda args: func(*args), task) for task in tasks]
 
     results = []
@@ -80,3 +80,7 @@ def run_with_executor(executor: Executor, func, tasks: List, timeout: int):
 
     return results
     """
+
+    futures = [executor.submit(lambda args: func(*args), task) for task in tasks]
+    results = [future.result() for future in futures]
+    return results