python - 是什么阻止我的异步代码运行异步？

Question

我正在尝试离开线程并开始使用异步。我尝试写一些简单的东西，这样我就可以更适应异步；由于某种原因，我的异步代码没有异步运行。

我在线程中重写了相同的代码，它运行速度快且并发，与异步代码不同。

普通代码

import time 
import random

def display(x: int) -> None:
    time.sleep(random.randint(1, 8))
    print(x)

def main():
    for i in range(10):
        display(i) 

if __name__ == '__main__':
    main()   

输出

0
1
2
3
4
5
6
7
8
9

异步代码

import time 
import random
import asyncio

async def display(x: int) -> None:
    await asyncio.sleep(random.randint(1, 8))
    print(x)

async def main():
    for i in range(10):
        await display(i)

if __name__ == '__main__':
    event_loop = asyncio.get_event_loop()
    event_loop.run_until_complete(main())
    event_loop.close()

输出

0
1
2
3
4
5
6
7
8
9

线程代码

import time 
import random 
import threading 

def display(x: int) -> None:
    time.sleep(random.randint(1, 8))
    print(x)

def main():
    threads = []

    for i in range(10):
        t = threading.Thread(target=display, args=[i])
        threads.append(t)
        t.start()

    for t in threads:
        t.join()


if __name__ == '__main__':
    main()

输出

5
9
3
0
4
2
1
8
6
7

Answer 1

await display(i) 使用参数 i 运行 display，它返回一个awaitable。然后，您立即使用 await 等待它，从而阻止调用。

如果您想将它们全部安排在一起，然后在最后等待，您需要将可等待项收集到一个列表中，然后立即等待所有它们。

import time
import random
import asyncio

async def display(x: int) -> None:
    await asyncio.sleep(random.randint(1, 8)/10)
    print(x)

async def main():
    awaitables = []
    for i in range(10):
        awaitables.append(display(i))
    await asyncio.wait(awaitables)

if __name__ == '__main__':
    event_loop = asyncio.get_event_loop()
    event_loop.run_until_complete(main())
    event_loop.close()

<小时/>

是的，因为否则肯定有人会指出这一点，你也可以将其写在列表理解中:

async def main():
    await asyncio.wait([display(i) for i in range(10)])

<小时/>

进一步说明:

我相信您已经知道了，但我认为无论如何提及它都很重要。代码运行异步，但不是并行。使用 async 或 threading.Thread 运行多个计算量大的函数仍然只能在一个 CPU 核心上运行，而没有任何加速。 Python 解释器是单线程的。