def METHOD_NAME(self, func, *args, **kwargs):
    """Run async func with args/kwargs in separate thread, returns Future object."""
    return asyncio.run_coroutine_threadsafe(func(*args, **kwargs), self._loop)