Added threading.RLock() to protect _invariants dict and _enforcement_records list
All public methods (add_invariant, remove_invariant, list_invariants, get_effective_invariants, enforce_invariants) now use lock protection
Prevents RuntimeError: dictionary changed size during iteration
Prevents data corruption from concurrent access
Follows existing pattern from AutonomyController and AutonomyGuardrailService

ISSUES CLOSED: #7524

@@ -0,0 +109,4 @@
+@when(
+    "{thread_count:d} threads perform random operations (add/list/remove/enforce) for {iterations:d} iterations each"
+)
+def step_concurrent_random_operations(

@@ -0,0 +326,4 @@
+    )
+
+
+@then("the final state should be consistent")

@@ -0,0 +211,4 @@
+        )
+        sys.exit(1)
+
+    decision_ids = [r.decision_id for r in enforcement_records]  # type: ignore[union-attr]

@@ -0,0 +207,4 @@
+        )
+        sys.exit(1)
+
+    decision_ids = [r.decision_id for r in enforcement_records]  # type: ignore[union-attr]

@@ -0,0 +211,4 @@
+    unique_ids = set(decision_ids)
+    if len(unique_ids) != len(decision_ids):
+        print(
+            f"FAIL: duplicate enforcement records: "

@@ -54,6 +62,7 @@ class InvariantService:
         Args:
             event_bus: Optional EventBus for domain event emission.
         """
+        self._lock: threading.RLock = threading.RLock()

@@ -0,0 +225,4 @@
+    )
+
+
+@then("the final state should be valid")

@@ -0,0 +240,4 @@
+    )
+
+
+@then("no thread should be starved")

@@ -0,0 +246,4 @@
+    assert context.operation_count > 0, "No operations were performed"
+
+
+@then("all operations should complete successfully")