1

我正在编写一个同时使用多处理和多线程的程序(python 2.7),多处理是使用 Celery 库完成的。我有一个必须使用多线程并行化的函数,因此我实现了一个共享的“输入”队列,该队列存储线程池的参数(使用 python multiprocessing.Manger 队列)以及我做出“响应”的每个进程队列,线程根据作业来自的源进程将计算结果存储在特定的“响应队列”中。问题是将结果存储在响应队列中导致内存泄漏, https://bugs.python.org/issue33081 我的问题是我可以用什么替代品来替换那些 python multiprocessing.Manager 队列,我考虑过使用 Pathos multiprocess.Manager 队列和管道(管道很适合我,因为有一个发布者和一个消费者)但有没有其他选项我可以在不重构代码的情况下尝试?谢谢 !

4

0 回答 0