Method worker

internbootcamp/src/base_evaluator.py:747–762

(idx, input_data)

        file_write_lock = asyncio.Lock()

        async def worker(idx, input_data):
            async with semaphore:
                result = await self._evaluate_one(input_data)
                results[idx] = result
                if output_path:
                    async with file_write_lock:
                        with open(output_path, "a", encoding="utf-8") as f:
                            try:
                                f.write(json.dumps(result, ensure_ascii=False) + "\n")
                            except Exception as e:
                                print(f"❌ 写入结果失败: {e}")
                                print(f"❌ 写入结果: {result}")
                
                # 任务完成时立即更新进度条
                async with progress_lock:
                    progress_bar.update(1)

        # 创建所有任务
        tasks = [worker(idx, input_data) for idx, input_data in enumerate(input_list)]