Как запустить задачу Asyncio, не ожидая? - PullRequest
Новая
       14

Как запустить задачу Asyncio, не ожидая?

2 голосов
/ 27 мая 2019

Мне нужно периодически вызывать задачу, но (a) время ожидания почти больше, чем период.

В следующем коде, как я могу запустить задачу do_somthing () без необходимости ждать результата? 

 import asyncio
 import time
 from random import randint

 period = 1  # Second


 def get_epoch_ms():
     return int(time.time() * 1000.0)


 async def do_somthing(name):
     print("Start  :", name, get_epoch_ms())
     try:
         # Do something which may takes more than 1 secs.
         slp = randint(1, 5)
         print("Sleep  :", name, get_epoch_ms(), slp)
         await asyncio.sleep(slp)
     except Exception as e:
         print("Error  :", e)

     print("Finish :", name, get_epoch_ms())


 async def main():
     i = 0
     while True:
         i += 1
         # Todo : this line should be change
         await do_somthing('T' + str(i))
         await asyncio.sleep(period)


 asyncio.get_event_loop().run_until_complete(main())

Ответы [ 2 ]

0 голосов
/ 27 мая 2019

Ваша проблема в использовании run_until_complete(main()), который не удовлетворяет вашей цели параллелизма, поэтому, предположив, что ваши сопрограммные задачи (do_somthing()) ограничены 5, ваш код будет таким, как показано ниже: 

import time
from random import randint

period = 1  # Second

def get_epoch_ms():
    return int(time.time() * 1000.0)

async def do_somthing(name):
    print("Start  :", name, get_epoch_ms())
    try:
        # Do something which may takes more than 1 secs.
        slp = randint(1, 5)
        print("Sleep  :", name, get_epoch_ms(), slp)
        await asyncio.sleep(slp)
    except Exception as e:
        print("Error  :", e)

    print("Finish :", name, get_epoch_ms())

loop = asyncio.get_event_loop()
futures = [loop.create_task(do_somthing('T' + str(i)))
           for i in range(5)]

loop.run_forever()

for f in futures:
    f.cancel()

Вот рабочий процесс параллелизма в его выводе: 

Start  : T0 1558937750705
Sleep  : T0 1558937750705 5
Start  : T1 1558937750705
Sleep  : T1 1558937750705 1
Start  : T2 1558937750705
Sleep  : T2 1558937750705 4
Start  : T3 1558937750705
Sleep  : T3 1558937750705 5
Start  : T4 1558937750705
Sleep  : T4 1558937750705 5
Finish : T1 1558937751707
Finish : T2 1558937754709
Finish : T0 1558937755707
Finish : T3 1558937755708
Finish : T4 1558937755708

Однако, если ваши сопрограммные задачи не ограничены, вы можете сделать это: 

...
async def main(loop):
    i = 0
    while True:
        i += 1
        loop.create_task(do_somthing('T' + str(i)))
        await asyncio.sleep(period)


loop = asyncio.get_event_loop()
loop.run_until_complete(main(loop))
0 голосов
/ 27 мая 2019

Вместо await вызова сопрограммы, вызовите asyncio.create_task, чтобы вызвать объект задачи, который работает в фоновом режиме. На следующей итерации вы можете проверить, выполнено ли задание, и соответственно дождаться / отменить его. (В противном случае asyncio будет жаловаться на сборку мусора, которую не ожидали.)

...