2

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

4

3 回答 3

8

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

于 2009-01-04T02:03:01.520 回答
2

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

于 2009-01-04T02:48:00.290 回答
1

如果您使用的是 python 3.0,请使用缓冲流。

于 2009-01-06T18:00:00.603 回答