0

Скажите, пожалуйста, каким правильно использовать запуска функций в асинхронном варианте? Есть список с вложенными списками. Где каждый список представляет из себя будущие значения для функции.

c = [[121, 'yes', 5],[345, 'no', 1]]

sphere = 121
dart = 'yes'
number = 5

Есть функция:

def test(sphere, dart, nubmer)

Я бы хотел совершить следующие действия

for element in c:
    sphere, dart, number = c[0], c[1], c[2]
    #дальше мне надо запускать функцию в асинхронном режиме.
    #Как мне сделать так, чтобы она сама завершалась? Это нужно прописывать в самой функции?
    #Или же надо останавливать поток непосредственно после каждого элемента итерации?



3
  • 2
    Показанная функция не является асинхронной, поэтому что значит "запуск асинхронных функций" и "в асинхронном режиме" - непонятно
    – andreymal
    20 сен 2021 в 10:24
  • Я неправильно сказал. Вы правы. Каждая функция запущенная с параметрами из списка должна исполняться отдельным поток до самозавершения. Так понятно?
    – Antony
    20 сен 2021 в 14:47
  • 1
    Ну значит просто взять и запустить этот самый отдельный поток threading.Thread(target=test, args=element).start()
    – andreymal
    20 сен 2021 в 14:49

1 ответ 1

1

Возможно, данное решение подойдёт для Вас:

import asyncio

async def test(sphere, dart, number): # Поменять def на async def.
    # Do Something.
    return

async def task_starter(input_array):
    for element in input_array:
        asyncio.create_task(test(element[0], element[1], element[2]))

loop = asyncio.get_event_loop()
future = asyncio.gather(coro_starter(c))
loop.run_forever() 

В таком случае будет ожидаться завершение работы Вашей функции.

5
  • Дак мне необходимо, что функция в итерации запускалась и итерация с запусками продолжилась. В самой функции будет таймер, который ее завершит. Вижу это так.
    – Antony
    20 сен 2021 в 9:56
  • 1
    Исправил, если на этот раз понял как Вы поставили задачу.
    – 6 crimes
    20 сен 2021 в 10:46
  • Спасибо, пойду разбирать и знакомиться. Выглядит не очень сложно.
    – Antony
    20 сен 2021 в 14:48
  • @6 crimes , а если async def test(sphere, dart, number) содержит другие функции? Они же не должны быть асинхронными?
    – Antony
    27 сен 2021 в 11:28
  • 1
    @Antony , что вы имеете ввиду? Если вы хотите вызвать из функции test другую функцию, то нет, не должны быть.
    – 6 crimes
    28 сен 2021 в 8:46

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.