当 await asyncio.sleep(0.01) 不够用时

Question

我有这个程序

import time
import asyncio


def is_prime(x):

    return not any(x//i == x/i for i in range(x-1, 1, -1))


async def highest_prime_below(x):

    print('Highest prime below %d' % x)
    for y in range(x-1, 0, -1):
        if is_prime(y):
            print('? Highest prime below %d is %d' % (x, y))
            return y
        await asyncio.sleep(0.01)
    return None


async def main():

    t0 = time.time()
    await asyncio.wait( [
        highest_prime_below(100000),
        highest_prime_below(10000),
        highest_prime_below(1000)
        ] )
    t1 = time.time()
    print('Took %.2f ms' % (1000*(t1-t0)))


loop = asyncio.get_event_loop()
loop.run_until_complete(main())
#loop.close()

发现素数。你也可以在这里看到它https://osf.io/w8u26/

我的问题是，假设我有太多的函数调用

await asyncio.wait( [
        highest_prime_below(100000),
        highest_prime_below(10000),
        highest_prime_below(1000)
        #100 function calls here
        ] )

我只有异步睡了这么多 await asyncio.sleep(0.01)

必须在设定的时间内完成所有功能，还是会在睡眠时间结束后取消某些功能？。

Answer 1

必须在设定的时间内完成所有功能，还是会在睡眠时间结束后取消某些功能？。

你的睡眠时间无关紧要；await asyncio.sleep()这里的唯一目的是强制 asyncio 暂停对事件循环的执行，并给其他任务一个运行的机会。你也可以等待asyncio.sleep(0)，你会达到同样的效果。

换句话说：不，函数的运行时间与睡眠中指定的时间没有任何关系。只要您使用asyncio.wait()等待所有协程，它们将在时间wait()返回时全部完成。增加睡眠时间只会使它们运行的​​时间更长。