update41

app.py

@@ -31,14 +31,16 @@ task_status = {}
 task_history = []
 # Lock for shared resources
 lock = threading.Lock()
-# Number of worker threads
-worker_threads = max(1, multiprocessing.cpu_count() // 2)  # Using half the available cores for better stability
+# Number of worker threads - set to 1 to process one task at a time
+worker_threads = 1  # 只处理一个任务，避免资源竞争
 # Flag for running background threads
 running = True
 # Mapping from task type to processing time
 task_type_times = {}
 # Currently processing tasks counter
 processing_count = 0
+# Available CPU cores for task processing
+available_cores = multiprocessing.cpu_count()
 
 def queue_processor():
     """Process tasks in the queue"""
@@ -46,10 +48,10 @@ def queue_processor():
     
     while running:
         try:
-            # Only process if we haven't reached worker thread limit
+            # Only process if we're not already processing a task
             with lock:
                 if processing_count >= worker_threads:
-                    # Already at max capacity, wait and try again
+                    # Already processing a task, wait and try again
                     time.sleep(0.5)
                     continue
                     
@@ -184,9 +186,8 @@ def evaluate(input_data):
             
         results = []
         
-        # 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))
+        # Use all available cores for this single task but with a reasonable cap
+        max_workers = max(1, min(available_cores // 2, 8))
         
         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}
@@ -449,39 +450,50 @@ def ui_get_queue_info():
         </tr>
         """
     
+    # 增加更多详细信息到UI
+    queue_details = ""
+    if queue_info['waiting_tasks'] > 0:
+        queue_details = f"<p>当前有 {queue_info['waiting_tasks']} 个任务在等待队列中，预计等待时间：{format_time(queue_info['estimated_wait'])}</p>"
+    
+    processing_details = ""
+    if queue_info['active_tasks'] > 0:
+        processing_details = f"<p>当前有 {queue_info['active_tasks']} 个任务正在处理中</p>"
+    
     return f"""
     <div class="dashboard">
         <div class="queue-info-card main-card">
-            <h3 class="card-title">Queue Status Monitor</h3>
+            <h3 class="card-title">队列状态监控</h3>
             <div class="queue-stats">
                 <div class="stat-item">
                     <div class="stat-value">{queue_info['waiting_tasks']}</div>
-                    <div class="stat-label">Waiting</div>
+                    <div class="stat-label">等待中</div>
                 </div>
                 <div class="stat-item">
                     <div class="stat-value">{queue_info['active_tasks']}</div>
-                    <div class="stat-label">Processing</div>
+                    <div class="stat-label">处理中</div>
                 </div>
                 <div class="stat-item">
                     <div class="stat-value">{queue_info['worker_threads']}</div>
-                    <div class="stat-label">Worker Threads</div>
+                    <div class="stat-label">工作线程</div>
                 </div>
             </div>
             
             <div class="wait-time">
-                <p><b>Current Estimated Wait Time:</b> {format_time(queue_info['estimated_wait'])}</p>
-                <p class="last-update"><small>Last update: {datetime.now().strftime('%H:%M:%S')}</small></p>
+                <p><b>预计等待时间:</b> {format_time(queue_info['estimated_wait'])}</p>
+                {queue_details}
+                {processing_details}
+                <p class="last-update"><small>最后更新时间: {datetime.now().strftime('%H:%M:%S')}</small></p>
             </div>
         </div>
             
         <div class="queue-info-card history-card">
-            <h3 class="card-title">Recently Processed Tasks</h3>
+            <h3 class="card-title">最近处理的任务</h3>
             <table class="recent-tasks">
                 <thead>
                     <tr>
-                        <th>Task ID</th>
-                        <th>Request Time</th>
-                        <th>Processing Time</th>
+                        <th>任务ID</th>
+                        <th>请求时间</th>
+                        <th>处理时间</th>
                     </tr>
                 </thead>
                 <tbody>
@@ -661,14 +673,14 @@ launch_workers()
 
 # Create Gradio interface
 with gr.Blocks(css=custom_css) as demo:
-    gr.Markdown("# Code Evaluation Service")
-    gr.Markdown("Code evaluation service supporting multiple programming languages, using queue mechanism to process requests")
+    gr.Markdown("# 代码评估服务")
+    gr.Markdown("支持多种编程语言的代码评估服务，使用队列机制处理请求")
     
     with gr.Row():
         with gr.Column(scale=3):
             # Queue status info card
             queue_info_html = gr.HTML()
-            refresh_queue_btn = gr.Button("Refresh Queue Status", variant="primary")
+            refresh_queue_btn = gr.Button("刷新队列状态", variant="primary")
     
     # Hidden API interface components
     with gr.Row(visible=False):