update18

app.py

@@ -32,7 +32,7 @@ task_history = []
 # Lock for shared resources
 lock = threading.Lock()
 # Number of worker threads
-worker_threads = multiprocessing.cpu_count()
+worker_threads = max(1, multiprocessing.cpu_count() // 2)  # Using half the available cores for better stability
 # Flag for running background threads
 running = True
 # Mapping from task type to processing time
@@ -144,7 +144,11 @@ def evaluate(input_data):
             return {"status": "Exception", "error": "Input must be a list"}
             
         results = []
-        max_workers = multiprocessing.cpu_count()
+        
+        # Use a moderate number of workers for all language tests to ensure stability
+        # This prevents resource contention regardless of language
+        max_workers = max(1, min(multiprocessing.cpu_count() // 2, 4))
+        
         with concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) as executor:
             future_to_item = {executor.submit(evaluate_single_case, item): item for item in input_data}
             for future in concurrent.futures.as_completed(future_to_item):
@@ -173,13 +177,26 @@ def evaluate_single_case(input_data):
         if not completions:
             return {"status": "Exception", "error": "No code provided"}
 
+        # Use a retry mechanism for all languages for better reliability
+        max_retries = 2  # One retry for all languages
+        
         results = []
         for comp in completions:
             code = input_data.get('prompt') + comp + '\n' + input_data.get('tests')
-            result = evaluate_code(code, language)
-            if result["status"] == "OK":
-                return result
-            results.append(result)
+            
+            # Try up to max_retries + 1 times for all test cases
+            for attempt in range(max_retries + 1):
+                result = evaluate_code(code, language)
+                
+                # If success or last attempt, return/record the result
+                if result["status"] == "OK" or attempt == max_retries:
+                    if result["status"] == "OK":
+                        return result
+                    results.append(result)
+                    break
+                    
+                # For retries, briefly wait to allow resources to stabilize
+                time.sleep(0.3)
             
         return results[0]