feat: candidate_filter 加单例守卫（规范5.3）

2026-08-10 15:19:47 +08:00
parent 7cdaa41f6f
commit 4e10ca9ab1
1 changed files with 9 additions and 0 deletions
@@ -373,6 +373,15 @@ def stage5_fundamental(code, name, price):
 # ── 主流程 ──

 def main():
+    # ── 单例守卫（规范5.3，2026-08-10）──
+    import fcntl
+    lock_f = open("/tmp/candidate_filter.lock", "w")
+    try:
+        fcntl.flock(lock_f, fcntl.LOCK_EX | fcntl.LOCK_NB)
+    except OSError:
+        print("[FILTER] 已有实例在运行，退出")
+        return
+
    stage_filter = None
    single_code = None
    for i, arg in enumerate(sys.argv[1:]):