python - 让 asyncio 按顺序运行函数 (Python 3)

Question

这是一个使用 asyncio 打印 0 到 9 数字的简单示例。

问题:有时代码会打印出从 0 到 7 的数字，然后打印 9，然后是 8。特别是当您将 ThreadPoolExecutor 设置为较小的数字(例如 4 或5.

0
1
2
3
4
5
6
7
9
8

如何让它总是按0到9的顺序打印？为什么没有按顺序打印？

0
1
2
3
4
5
6
7
8
9

代码

import asyncio
from concurrent.futures import ThreadPoolExecutor


async def printThreaded(THREAD_POOL, length):   
    loop = asyncio.get_event_loop()
    futures = []
    for i in range(length):
        futures.append(loop.run_in_executor(THREAD_POOL, echo, i))
    await asyncio.wait(futures)


def echo(i):
    print(i)


THREAD_POOL = ThreadPoolExecutor(16)
with THREAD_POOL:
    loop = asyncio.get_event_loop()
    length = 10
    loop.run_until_complete(printThreaded(THREAD_POOL, length))

Answer 1

您的代码现在发生了什么？

您创建协程列表(futures)，每个协程将在线程池中运行echo，而不是一次性启动它们(await asyncio.wait( future ))。由于多个 echo 同时运行，并且每个打印都在运行，因此所有这些打印都可能随时发生。

你想做什么？

您可能并不真的想按顺序运行协程(否则您可以在没有asyncio的情况下在循环中调用它)，您希望在线程池中同时运行它们，但打印他们的结果按照协程创建的顺序排列

在这种情况下，您应该:

1. 将线程中发生的实际工作从打印它

2. 可能更喜欢使用 asyncio.gather按顺序获得计算结果

3. 最后打印在主线程中得到的有序结果

摘要

这是上面解释的代码的修改版本:

import time
from random import randint

import asyncio
from concurrent.futures import ThreadPoolExecutor


async def printThreaded(THREAD_POOL, length):   
    loop = asyncio.get_event_loop()

    # compute concurrently:
    coroutines = []
    for i in range(length):
        coroutine = loop.run_in_executor(THREAD_POOL, get_result, i)
        coroutines.append(coroutine)
    results = await asyncio.gather(*coroutines)

    # print ordered results:
    for res in results:
        print(res)



def get_result(i):

    time.sleep(randint(0, 2))  # actual work, reason you delegate 'get_result' function to threaed

    return i  # compute and return, but not print yet


THREAD_POOL = ThreadPoolExecutor(4)
with THREAD_POOL:
    loop = asyncio.get_event_loop()
    length = 10
    loop.run_until_complete(printThreaded(THREAD_POOL, length))