#467 Race Condition: notification_count increment without lock in activity_worker.py

engine/services/activity_worker.py:252-254 increments notification_count without synchronization. In threaded environment, count += 1 is not atomic. Multiple threads can read same value and increment, losing counts. FIX: Use threading.Lock or atomic counter (e.g., itertools.count or threading.local).