throttler_async_rate_limiting_with_context_manager.py

1import asyncio
2import time
3from throttler import Throttler
4
5async def main():
6    # Allow 5 calls every 1 second
7    throttler = Throttler(rate_limit=5, period=1.0)
8    
9    start_time = time.perf_counter()
10    
11    async def task(i):
12        async with throttler:
13            print(f"Task {i} started at {time.perf_counter() - start_time:.2f}s")
14
15    # Run 10 tasks (should take ~2 seconds total)
16    await asyncio.gather(*(task(i) for i in range(10)))
17
18if __name__ == "__main__":
19    asyncio.run(main())