Python, чистый способ проверить, завершена ли задача - PullRequest
Новая
       10

Python, чистый способ проверить, завершена ли задача

0 голосов
/ 16 апреля 2019 
loop = asyncio.get_event_loop()
executor = concurrent.futures.ThreadPoolExecutor(max_workers=5)
tasks = [loop.run_in_executor(executor, self.parse_url, url) for url in urls]
await asyncio.wait(tasks, timeout=5)
for (i, task) in zip(urls, tasks):
    result = task.result() if task._state.lower() == 'finished' else []

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

Есть ли более чистый способ сделать это?Я не думаю, что должен получить доступ к свойству _state, как это.

1 Ответ

2 голосов
/ 16 апреля 2019

Вы можете использовать task.done(), чтобы проверить, завершена ли задача.

Кроме того, asyncio.wait() сама возвращает два набора задач: те, которые фактически завершились, и те, которыенет, поэтому вы можете выполнять итерацию только над набором done: 

done, pending = await asyncio.wait(tasks, timeout=5)
for t in done:
    ...
...