pass in a bunch of synchronous partials to get executed concurrently

runasync.py

"""
pass in a bunch of synchronous partials to get executed concurrently
example:
import asyncio
import functools
        user_can_read = lambda res: functools.partial(
            perms.can_read, some_user, some_res, some_perms,
        )
        is_readable = await async_gather(map(user_can_read, items)

"""


async def async_gather(synchronous_partials):
    loop = asyncio.get_running_loop()
    gathers = []
    with concurrent.futures.ThreadPoolExecutor(max_workers=5) as pool:
        for sp in synchronous_partials:
            gathers.append(loop.run_in_executor(pool, sp))
    return await asyncio.gather(*gathers)