在celery中向工作线程池动态添加/删除线程

Question

如何从一个任务中向当前的多处理池添加更多的线程（并删除线程）（即，运行celeryd时使用的是celeryd_CONCURRENCY=10，但我想立即将其更改为celeryd_CONCURRENCY=15）？在

有一个名为celery.concurrency.processes.TaskPool.Pool.grow的函数，但我不知道如何从正在运行的任务中调用它，也不知道它是否是正确的函数。在

Answer 1

阅读来源：

https://github.com/ask/celery/blob/master/celery/concurrency/processes/__init__.py

有grow()和{}，尽管后者看起来有点可疑。在

您需要在某处保留对池的引用，如果只有一个池，请将其保持全局。在

警告海报：如果多处理实际上意味着运行多个独立的进程，那么当你试图缩小或增长时，你可能已经在一个子进程中了，这显然行不通。在