如何在python脚本中正确导入Billiard以使用Queue

Question

我知道这些问题听起来很愚蠢，但我没有找到解决方案。

在Billiard的文档中，所有的进口看起来都像：

from multiprocessing import Process, Queue

当我这样导入时，我使用的不是台球，而是内置的python多处理包，因为我使用的是Celery，所以它对我不起作用。

如果我这样导入：

from billiard.context import Process
from billiard.queues import Queue

当我实例化队列时，我收到以下错误：

TypeError: missing 1 required keyword-only argument: ctx

我使用的是Python 2.7

Answer 1

这应该有效：

from billiard import Process, Queue