Python3 Asyncio 在并发任务之间共享资源

Question

我有一个用 Python3.5 编写的网络应用程序，它利用 pythons Asyncio 同时处理每个传入连接。

在每个并发连接上，我想将连接的客户端数据存储在一个列表中。我担心如果两个客户端同时连接（这是可能的），那么两个任务都会尝试同时写入列表，这肯定会引发问题。我将如何解决这个问题？

Answer 1

asyncio 仅在 yield 点（await 表达式）上进行上下文切换，因此两个并行任务不会在相同时间执行。

但如果仍然可能出现竞争条件（这取决于具体的代码结构），您可以使用asyncio synchronization primitives 和queues。

Answer 2

您的问题中缺少很多信息。

• 您的应用程序是否线程化？如果是，那么您必须将您的列表包含在 threading.Lock 中。
• 您是否在请求处理程序的写入（到列表）之间切换上下文（例如使用await）？如果是，那么您必须将您的列表包含在 asyncio.Lock 中。
• 您是否进行多处理？如果是，那么您必须使用multiprocessing.Lock
• 您的应用程序是否划分到多台机器上？然后你必须使用一些外部共享数据库（例如 Redis）。

如果所有这些问题的答案都是否，那么您无需执行任何操作，因为单线程异步应用无法并行更新共享资源。