self: 限制并发量asyncio

返回上一步 / in None
  1. #coding:utf-8
  2. import time,asyncio
  4. a=time.time()
  6. id=1
  7. async def hello(id,semaphore):
  8. async with semaphore:
  9. await asyncio.sleep(1)
  10. print('working id:'+str(id))
  12. async def run():
  13. semaphore = asyncio.Semaphore(5) # 限制并发量为5
  14. to_get = [hello(id,semaphore) for id in range(20)] #总共20任务
  15. await asyncio.wait(to_get)
  18. if __name__ == '__main__':
  19. loop = asyncio.get_event_loop()
  20. loop.run_until_complete(run())
  21. loop.close()
  22. print(time.time()-a)
搜索