python - 异步信号量和等待任务排序模式

Question

考虑以下代码来管理具有相同异步任务的并发性

import asyncio

async def performTask(id):

  await asyncio.sleep(1)
  print(id)


async def runBatchItem(semaphore, task):
  await semaphore.acquire()
  await task
  semaphore.release()


async def main():

  # all tasks
  tasks = [performTask(i) for i in range(20)]

  # concurrency handler
  MAX_CONCURRENT = 3
  semaphore = asyncio.Semaphore(value=MAX_CONCURRENT)
  stasks = [runBatchItem(semaphore, task) for task in tasks]

  await asyncio.wait(stasks)


asyncio.run(main())

无论我多久运行一次，我总是得到以下输出序列

3 19 4 5 6 7 8 17 9 10 11 12 13 0 14 1 15 2 16 18

• 问题 1. 我的任务排序的逻辑是什么？
• 问题 2. 如果我希望以近似的插入顺序处理任务怎么办？即，就像通过有限并发的队列工作一样。

提前致谢！

标签： pythonpython-asyncio

Answer 1

正如 Andrew Svetlov（异步开发人员）在这里回答的那样：

该顺序是不确定的.wait()规范。

如果你在另一台机器上启动你的脚本，你会得到不同的结果。如果您想对任务执行施加顺序，您可以只await在循环中为它们执行或使用异步同步原语，例如协程Event或Condition在协程中。