Method queue_for_eval

src/benchmark/leetcode.py:981–1005

将任务加入评测队列。当队列达到 batch_size 时自动触发批量评测。 使用锁确保同一时间只有一个 task 入队列。 Args: task: 已完成推理的任务 Returns: 是否触发了批量评测

(self, task: Task)

        logger.info(f"| 💾 [Task {task.task_id}] Error result saved directly (prediction: {prediction})")

    async def queue_for_eval(self, task: Task) -> bool:
        """
        将任务加入评测队列。当队列达到 batch_size 时自动触发批量评测。
        使用锁确保同一时间只有一个 task 入队列。
        
        Args:
            task: 已完成推理的任务
            
        Returns:
            是否触发了批量评测
        """
        async with self._queue_lock:
            self._pending_queue.append(task)
            queue_size = len(self._pending_queue)
            
            # 实时打印队列状态
            print(f"\r📊 Queue: {queue_size}/{self.batch_size} tasks", end="", flush=True)
            logger.info(f"| 📥 [Task {task.task_id}] Added to queue ({queue_size}/{self.batch_size})")
            
            # 当队列达到 batch_size 时，自动触发批量评测
            if queue_size >= self.batch_size:
                print()  # 换行
                await self.flush_eval_queue()
                return True
            return False
    
    async def flush_eval_queue(self) -> List[Task]:
        """