在 Python 中实现类似缓冲区的结构

Question

我正在尝试编写一个小型 wsgi 应用程序，它会在每次请求后将一些对象放入外部队列。我想批量制作，即。使网络服务器将对象放入内存中的类似缓冲区的结构中，并在缓冲区足够大或特定超时后将这些对象批量发送到队列的另一个线程和/或进程，并清除缓冲区。我不想陷入 NIH 综合症，也不想打扰线程的东西，但是我找不到适合这项工作的代码。有什么建议么？

Answer 1

检查https://docs.python.org/library/queue.html，看看它是否满足您的需求。

Answer 2

由于您编写了“线程和/或进程”，另请参阅 2.6 中的 multiprocessing.Queue and multiprocessing.JoinableQueue。这些是 Queue 的进程间变体。

Answer 3

如果您使用的是 python 3.0，请使用 buffered stream。