AsyncIO python как не ждать ответ от функции?

Question

[0ralo]

Здравсвуйте,у меня проблема с выполнением моего кода,и я пролазил весь интернет и не смог найти ответа на мой вопрос(извините) так вот,элементарный пример:

def first():
    sleep(30)
    print(2)
def second():
    sleep(20)
    print(1)
    
def main():
    first()
    second()
    print("Продолжаем")
main()

Я хочу что бы вывод был таким:

Продолжаем
1
2

Я знаю что надо использовать AsyncIO
но я уже довольно продолжительное время не могу разобраться в этом модуле.Если можно я бы хотел увидеть рабочий пример моего "Кода" заранее спасибо.

Answer 1

[Ivan Yakushenko]

Для вашей задачи лучше подойдут потоки.

from time import sleep
from threading import Thread


def first():
    sleep(3)
    print(2)


def second():
    sleep(3)
    print(1)
    

def main():
    Thread(target=first).start()
    Thread(target=second).start()
    print("Продолжаем")


main()

PS D:\Dropbox\Develop\all_tests> python threads.py
Продолжаем
1
2

Comments

[Владимир Олохтонов]

Главное не рассказывайте человеку про общую память и конкурентное обращение к разделяемым переменным, а то всё будет выглядеть гораздо сложнее :)

[Ivan Yakushenko]

Владимир Олохтонов, и к чему это?

[Владимир Олохтонов]

Ivan Yakushenko, к тому, что предложенное вами решение подразумевает целую гору подводных камней, о которых вы автора (явно новичка) не предупредили.

Ведь вы же не думаете, что ему действительно нужно вызывать sleep и print в этих функциях? :)

[Ivan Yakushenko]

Владимир Олохтонов, и какие подводные камни с ними могут быть? Чет я уже пол года активно использую потоки в некоторых своих работах и всё еще не наткнулся на них.

[Владимир Олохтонов]

Ivan Yakushenko, вы меня удивляете. Вы когда-нибудь пробовали в одном потоке инкрементить переменную, а в другом проверять её значение?

import time
import threading


x = 0

def incr():
    global x
    if x != 10:
        time.sleep(0.1)
        x += 10

t1 = threading.Thread(target=incr)
t2 = threading.Thread(target=incr)

t1.start()
t2.start()

t1.join()
t2.join()

print(x)

[Владимир Олохтонов]

Возвращаясь к вопросу автора: решение предложено правильное, но оно совсем не такое простое как кажется на первый взгляд.

Прежде чем писать код, работающий с потоками, нужно обязательно понять суть многопоточности и вдумчиво прочитать пару статей на эту тему, иначе вы будете страдать на каждом шагу и вероятнее всего получите нестабильную программу, делающую не то что вам хотелось.

[Ivan Yakushenko]

Владимир Олохтонов, это не относится конкретно к потокам, это относится в целом к конкурентности. При этом потоки - это самый простой способ реализовать параллельное выполнение кода.
Автор явно только начал изучать программирование и у него появился вопрос "а как параллельно выполнять код" - ему не нужно перерывать все особенности многопоточности, он получил ответ на свой вопрос и дальше пойдут изучать программирование, попутно спотыкаясь и подымаясь.

[Владимир Олохтонов]

Ivan Yakushenko, в целом да, однако при использовании кооперативной многозадачности (asyncio) такой проблемы не возникает, поскольку реальный поток исполнения всего один.

Answer 2

[AlexBoss]

Продолжаем
Ваш ответ:1
Ваш ответ:2

import asyncio

async def first():
    await asyncio.sleep(30)
    return (2)
async def second():
    await asyncio.sleep(20)
    return (1)
    
async def main():
    print("Продолжаем")
    for fut in asyncio.as_completed([first(), second()]):
        resp = await fut
        print(f'Ваш ответ:{resp}')
asyncio.run(main())