Semaphoreを使ってPythonの非同期処理の平行処理数をコントロールする

import asyncio class AsyncResource: def __init__(self, concurrency: int = 10): self.semaphore = asyncio.Semaphore(concurrency) async def task(self): async with self.semaphore: # 11個目以降のタスクはここでブロックされる print("Hello") await self.call_api() print("World") async def call_api(self): await asyncio.sleep(1) async def main(): async_resource = AsyncResource() tasks = [async_resource.task() for _ in range(10