Function consumer

tests/integration/test_lock_behavior.py:213–225

Process items from queue with lock.

(consumer_id: str)

            await asyncio.sleep(0.01)  # Simulate arrival rate

    async def consumer(consumer_id: str):
        """Process items from queue with lock."""
        while True:
            try:
                item = await asyncio.wait_for(queue.get(), timeout=0.5)
            except asyncio.TimeoutError:
                break

            async with lock:
                # Simulate processing
                await asyncio.sleep(0.02)
                processed_order.append((consumer_id, item["id"]))
                queue.task_done()

    # Start producer and two consumers concurrently
    producer_task = asyncio.create_task(producer(5))