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

有帮助吗?

解决方案

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

其他提示

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

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

许可以下: CC-BY-SA归因
不隶属于 StackOverflow
scroll top