Class BrowserCaptchaService

src/services/browser_captcha.py:2540–3079

多浏览器轮询打码服务（单例模式） 支持配置浏览器数量，每个浏览器只开 1 个标签页，请求轮询分配

class BrowserCaptchaService:
    """多浏览器轮询打码服务（单例模式）
    
    支持配置浏览器数量，每个浏览器只开 1 个标签页，请求轮询分配
    """
    
    _instance: Optional['BrowserCaptchaService'] = None
    _lock = asyncio.Lock()
    
    def __init__(self, db=None):
        self.db = db
        self.website_key = "6LdsFiUsAAAAAIjVDZcuLhaHiDn5nnHVXVRQGeMV"
        self.base_user_data_dir = os.path.join(os.getcwd(), "browser_data_rt")
        self._browsers: Dict[int, TokenBrowser] = {}
        self._browsers_lock = asyncio.Lock()
        self._slot_allocation_lock = asyncio.Lock()
        self._slot_reservations: Dict[int, int] = {}
        
        # ???????
        self._browser_count = 1  # ?? 1 ?????????
        self._round_robin_index = 0  # ????
        # ????
        self._stats = {
            "req_total": 0,
            "gen_ok": 0,
            "gen_fail": 0,
            "api_403": 0
        }
        
        # ?????? _load_browser_count ???????
        self._token_semaphore = None
        self._idle_reaper_task: Optional[asyncio.Task] = None
    
    async def _ensure_idle_reaper(self):
        if self._idle_reaper_task is None or self._idle_reaper_task.done():
            self._idle_reaper_task = asyncio.create_task(self._idle_reaper_loop())

    async def _idle_reaper_loop(self):
        while True:
            try:
                await asyncio.sleep(15)
                idle_ttl = int(getattr(config, "browser_idle_ttl_seconds", 600) or 600)
                browsers = []
                async with self._browsers_lock:
                    browsers = list(self._browsers.values())
                for browser in browsers:
                    try:
                        if browser.is_busy():
                            continue
                        if not browser.has_shared_browser():
                            continue
                        if browser.idle_seconds() < idle_ttl:
                            continue
                        await browser.recycle_browser(reason=f"idle_ttl_{idle_ttl}s", rotate_profile=False)
                    except Exception as e:
                        debug_logger.log_warning(f"[BrowserCaptcha] idle reaper failed: {e}")
            except asyncio.CancelledError:
                return