背景:我有一个当前的实现,它从 python 中大约 120 个不同的套接字连接接收数据。在我当前的实现中,我处理每个单独的套接字连接,每个连接都有一个专用线程。这些线程中的每一个都解析数据并最终将其存储在共享锁定字典中。这些套接字没有统一的数据速率,一些套接字比其他套接字获得更多的数据。
问题:这是在 python 中处理传入数据的最佳方式,还是 python 有更好的方式来处理每个线程的多个套接字?
背景:我有一个当前的实现,它从 python 中大约 120 个不同的套接字连接接收数据。在我当前的实现中,我处理每个单独的套接字连接,每个连接都有一个专用线程。这些线程中的每一个都解析数据并最终将其存储在共享锁定字典中。这些套接字没有统一的数据速率,一些套接字比其他套接字获得更多的数据。
问题:这是在 python 中处理传入数据的最佳方式,还是 python 有更好的方式来处理每个线程的多个套接字?
正如您在阅读异步 UDP 套接字的问题中提到的,asyncoro可用于有效地处理许多异步套接字。在您的问题中使用 asyncoro 的另一个好处是您无需担心锁定共享字典,因为使用 asyncoro 在任何时候最多只有一个协程正在执行,并且没有强制抢占。