python - programming - Obtención de valores de funciones que se ejecutan como tareas asíncronas.

python async api

Question

Estaba probando el siguiente código:

import asyncio

@asyncio.coroutine
def func_normal():
        print("A")
        yield from asyncio.sleep(5)
        print("B")
        return ''saad''

@asyncio.coroutine
def func_infinite():
    i = 0
    while i<10:
        print("--"+str(i))
        i = i+1
    return(''saad2'')

loop = asyncio.get_event_loop()

tasks = [
    asyncio.async(func_normal()),
    asyncio.async(func_infinite())]

loop.run_until_complete(asyncio.wait(tasks))
loop.close()

No puedo averiguar cómo obtener valores en las variables de estas funciones. No puedo hacer esto

asyncio.async(a = func_infinite())

ya que esto haría de este un argumento de palabra clave. ¿Cómo hago para lograr esto?

Answer 1

Los coroutines funcionan como están. Simplemente use el valor devuelto de loop.run_until_complete() y llame a asyncio.gather() para recopilar múltiples resultados :

#!/usr/bin/env python3
import asyncio

@asyncio.coroutine
def func_normal():
    print(''A'')
    yield from asyncio.sleep(5)
    print(''B'')
    return ''saad''

@asyncio.coroutine
def func_infinite():
    for i in range(10):
        print("--%d" % i)
    return ''saad2''

loop = asyncio.get_event_loop()
tasks = func_normal(), func_infinite()
a, b = loop.run_until_complete(asyncio.gather(*tasks))
print("func_normal()={a}, func_infinite()={b}".format(**vars()))
loop.close()

Salida

--0
--1
--2
--3
--4
--5
--6
--7
--8
--9
A
B
func_normal()=saad, func_infinite()=saad2

Answer 2

Si desea utilizar cualquier valor devuelto por coroutine tan pronto como termine, puede pasar un objeto futuro al coro y actualizar este futuro mediante un valor calculado. Tan pronto como se actualice el futuro, pasa su future.result () a la función de devolución de llamada que está vinculada con el futuro dado. Ver código a continuación:

import asyncio


async def func_normal(future):
    print("A")
    await asyncio.sleep(5)
    print("B")
    # return ''saad''
    future.set_result(''saad'')


async def func_infinite(future):
    i = 0
    while i<10:
        print("--"+str(i))
        i = i+1
    # return(''saad2'')
    future.set_result(''saad2'')

def got_result(future):
    print(future.result())

loop = asyncio.get_event_loop()
future1 = asyncio.Future()
future2 = asyncio.Future()

future1.add_done_callback(got_result)
future2.add_done_callback(got_result)

# Coros are automatically wrapped in Tasks by asyncio.wait() 
coros = [
    func_normal(future1),
    func_infinite(future2)]

loop.run_until_complete(asyncio.wait(coros))
loop.close()

La función de devolución de llamada se llama con un solo argumento: el objeto futuro con el que está vinculado. Si necesita pasar más argumentos a la devolución de llamada, utilice un paquete parcial de functools:

future1.add_done_callback(functools.partial(print, "future:", argin))

llamará

print("future:", argin)

Answer 3

loop.run_until_complete devuelve el valor devuelto por la función que le pasa. Entonces, devolverá la salida de asyncio.wait :

import asyncio

@asyncio.coroutine
def func_normal():
    print("A")
    yield from asyncio.sleep(5)
    print("B")
    return ''saad''

@asyncio.coroutine
def func_infinite():
    i = 0
    while i<10:
        print("--"+str(i))
        i = i+1
    return(''saad2'')

loop = asyncio.get_event_loop()

tasks = [
    asyncio.async(func_normal()),
    asyncio.async(func_infinite())]

done, _ = loop.run_until_complete(asyncio.wait(tasks))
for fut in done:
    print("return value is {}".format(fut.result()))
loop.close()

Salida:

A
--0
--1
--2
--3
--4
--5
--6
--7
--8
--9
B
return value is saad2
return value is saad

También puede acceder a los resultados directamente desde la matriz de tasks :

print(tasks[0].result())
print(tasks[1].result())