From 3ea14a85c30fc570ca4118025323bce1eaf3149f Mon Sep 17 00:00:00 2001 From: UnCLAS-Prommer Date: Mon, 9 Mar 2026 15:08:42 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=AE=80=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pytests/config_test/test_file_watcher.py | 16 +++------------- 1 file changed, 3 insertions(+), 13 deletions(-) diff --git a/pytests/config_test/test_file_watcher.py b/pytests/config_test/test_file_watcher.py index a6b86477..95ebb525 100644 --- a/pytests/config_test/test_file_watcher.py +++ b/pytests/config_test/test_file_watcher.py @@ -107,16 +107,6 @@ async def test_unsubscribe_stops_dispatch(tmp_path: Path): assert calls == 0 -async def _wait_for(predicate, timeout: float = 5.0, interval: float = 0.05): - """轮询等待 predicate() 为真，避免依赖固定 sleep 导致跨平台不稳定。""" - deadline = asyncio.get_event_loop().time() + timeout - while asyncio.get_event_loop().time() < deadline: - if predicate(): - return - await asyncio.sleep(interval) - raise TimeoutError(f"等待超时({timeout}s)") - - @pytest.mark.asyncio async def test_add_callback_while_watcher_running(tmp_path: Path): dirs = (tmp_path / "a_dir").resolve() @@ -137,12 +127,12 @@ async def test_add_callback_while_watcher_running(tmp_path: Path): try: with file.open("w") as f: f.write("change") - await _wait_for(lambda: calls >= 1) + await asyncio.sleep(0.2) assert calls == 1 watcher.unsubscribe(uuid) with file.open("w") as f: f.write("change2") - await asyncio.sleep(1.0) + await asyncio.sleep(0.2) assert calls == 1 finally: - await watcher.stop() \ No newline at end of file + await watcher.stop()