ryg/royalnet
ryg/royalnet
1
Fork 0
mirror of https://github.com/RYGhub/royalnet.git synced 2024-11-23 19:44:20 +00:00
Code Activity

Document a function

Browse source
This commit is contained in:
Steffo 2019-12-30 01:52:44 +01:00
parent 6f9fd4e4f0
commit aa2bf78757
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
royalnet/utils/asyncify.py
View file

@ -4,10 +4,16 @@ import typing
async def asyncify(function: typing.Callable, *args, loop: typing.Optional[asyncio.AbstractEventLoop] = None, **kwargs): async def asyncify(function: typing.Callable, *args, loop: typing.Optional[asyncio.AbstractEventLoop] = None, **kwargs):
"""Asyncronously run the function in a different thread or process, preventing it from blocking the event loop. """Asyncronously run the function in a executor, allowing it to run asyncronously.
Args:
function: The function to call.
args: The arguments to pass to the function.
kwargs: The keyword arguments to pass to the function.
loop: The loop to run the function in. If :const:`None`, run it in in the current event loop.
Warning: Warning:
If the function has side effects, it may behave strangely.""" The called function must be thread-safe!"""
if not loop: if not loop:
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
return await loop.run_in_executor(None, functools.partial(function, *args, **kwargs)) return await loop.run_in_executor(None, functools.partial(function, *args, **kwargs))