СС
io
with_threads
4.576418876647949
with_processes
1.6963634490966797
synchronously
9.86125659942627
with_async_pool
2.0167219638824463
with_async_warp_sync_requests
3.9910428524017334
Size: a a a
СС
T
СС
T
СС
T
СС
T
СС
@timeit
def with_async_wrap_sync_requests():
loop = asyncio.get_event_loop()
async def async_get():
return requests.get(url)
async_tasks = [loop.create_task(async_get()) for _ in range(count)]
return loop.run_until_complete(asyncio.gather(*async_tasks))СС
T
io
with_threads 1.5259582996368408
with_processes 1.384183406829834
with_async_pool 1.515976905822754
with_async_wrap_sync_requests 9.314067840576172
synchronously 9.148640632629395
T
СС

T
T
T
ТЭ
@timeit
def with_async_wrap_sync_requests():
loop = asyncio.get_event_loop()
async def async_get():
return requests.get(url)
async_tasks = [loop.create_task(async_get()) for _ in range(count)]
return loop.run_until_complete(asyncio.gather(*async_tasks))ТЭ
@timeit
def with_async_wrap_sync_requests_aiohttp():
loop = asyncio.get_event_loop()
import aiohttp
async def get():
async with aiohttp.ClientSession() as session:
async with session.get(url) as response:
print(response.status)
async_tasks = [loop.create_task(get()) for _ in range(count)]
return loop.run_until_complete(asyncio.gather(*async_tasks))
ТЭ
response.status