Path: csiph.com!feeder.erje.net!2.eu.feeder.erje.net!newsfeed.freenet.ag!newsfeed.kamp.net!newsfeed.kamp.net!fu-berlin.de!uni-berlin.de!not-for-mail
From: Ray Cote <rgacote@appropriatesolutions.com>
Newsgroups: comp.lang.python
Subject: Adding run_in_executor task to already existing loop.
Date: Fri, 25 Mar 2016 16:24:13 -0400
Lines: 36
Message-ID: <mailman.7.1458937485.28225.python-list@python.org>
Mime-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable
Precedence: list
Xref: csiph.com comp.lang.python:105700

Hello:

I=E2=80=99m trying to perform an synchronous task while using asyncio.
I understand the solution is to use run_in_executor.
I=E2=80=99m not clear on how to add this into an already running event loop=
.

I=E2=80=99ve found lots of examples showing how to set up a loop and run th=
is, but
I=E2=80=99m blocked in regards to doing this when the loop is already estab=
lished.


Example code:

def blocking_func(param1):
    # call the blocking call here.
    return results

async def process_request():
    loop =3D asyncio.get_event_loop()
    block =3D loop.run_in_executor(None, blocking_func, =E2=80=9Chello=E2=
=80=9D)
    results =3D await loop.run_until_complete(asyncio.gather(*[block, ])

The above code says =E2=80=9Cloop already running.=E2=80=9D because we=E2=
=80=99re already in an
async ask that has been awaited. What is the proper method of adding in
this new synchronous task?

Regards
=E2=80=94Ray
--=20
Raymond Cote, President
voice: +1.603.924.6079 email: rgacote@AppropriateSolutions.com skype:
ray.cote