主页 / 问题 / 1114822
Accepted
Yuriy Tigiev
Asked:2020-04-24 03:27:34 +0000 UTC2020-04-24 03:27:34 +0000 UTC

如何在控制台中统计和显示 asyncio.gather() 中正在运行的协程的数量

  • 772

coroutine如何在控制台中统计和显示工作的人数asyncio.gather()？

您需要定期在控制台中显示有多少正在coroutines运行。

            tasks = ( self.FetchOHCL(pair, 7*12, '2h', False, 3, 60) for pair in pairs)
            results = await aio.gather(*tasks, return_exceptions=True)
python-3.x

2 个回答

  1. Best Answer

    一次只能完成一项任务，但您可以计算其中有多少未完成。例如，在定时器上挂上如下结构：

    count = len(filter( lambda x: x.done() == False, tasks))

    但是带有等待的典型变体更好。

    pending = tasks

while pending:
    done, pending = await asyncio.wait(
        pending, 
        timeout=10, 
        return_when=asyncio.FIRST_COMPLETED
    )
    print(datetime.datetime.now(), len(pending), end='\r')

    在这里，每 10 秒打印一次，并在每项任务完成时打印一次。

    • 1

  2. 更新了@eri 代码

    pending = list( tasks )

    while pending:
        done, pending = await aio.wait(
                    pending, 
                    #timeout=30, 
                    return_when=aio.FIRST_COMPLETED
                )
        result = [future.result() for future in done][0]
        resultsList.append(result)
    • 0

相关问题