Async Workers using Threads

async_workers.py

import requests
import asyncio
import sys
from functools import partial
from concurrent.futures import ThreadPoolExecutor
from contextlib import contextmanager

loop = asyncio.get_event_loop()


@contextmanager
def async_workers():
    with ThreadPoolExecutor(max_workers=10) as executor:
        yield partial(loop.run_in_executor, executor, requests.get)


async def get_pages(urls):
    with async_workers() as get_page:
        futures = [get_page(url) for url in urls]

    for response in await asyncio.gather(*futures):
        print(response.status_code)


if __name__ == '__main__':
    urls = ['http://examples.com', 'http://example.org']
    loop.run_until_complete(get_pages(urls))