我想有一个队列工作者管理工具，它允许添加新的队列，并将作业注册到这些队列中，生成工作者来处理这些作业。
到目前为止我有这个代码：

from redis import Redis
from rq import Queue, Retry, Worker

class WorkerPool: # TODO: find a better name
    def __init__(self):
        self._queues = {}
        self._workers = []
        self._redis_conn = Redis()

    def _get_queue(self, name):
        try:
            return self._queues[name]
        except KeyError:
            new_queue = Queue(name, connection=self._redis_conn)
            self._queues[name] = new_queue

            new_worker = Worker([new_queue], connection=self._redis_conn, name=name)
            new_worker.work() # Blocking :(

            return new_queue

    def add_job(self, queue, func, *func_args):
        q = self._get_queue(queue)
        job = q.enqueue(func, *func_args, retry=Retry(max=3))
        return job

正如我们所看到的 work() 函数阻止执行，而我希望它在后台工作。我想我可以在这里创建另一个线程-然后调用 work() 从一个线程，而主线程返回的工作，然而，这似乎有点尴尬我。有内置的吗 Redis （或其他已知模块）解决方案？
ps，欢迎给我的班级起更好的名字：）
这是我对多处理it的看法（由于来自非法线程的信号，线程将无法工作）：

import multiprocessing as mp
from redis import Redis
from rq import Queue, Retry, Worker

class WorkerPool: # TODO: find a better name
    def __init__(self):
        self._queues = {}
        self._worker_procs = []
        self._redis_conn = Redis()

    def __del__(self):
        for proc in self._worker_procs:
            proc.kill()

    def _get_queue(self, name):
        try:
            return self._queues[name]
        except KeyError:
            new_queue = Queue(name, connection=self._redis_conn)
            self._queues[name] = new_queue

            new_worker = Worker([new_queue], connection=self._redis_conn, name=name)
            worker_process = mp.Process(target=new_worker.work)
            worker_process.start()
            self._worker_procs.append(worker_process)

            return new_queue

    def add_job(self, queue, func, *func_args):
        q = self._get_queue(queue)
        job = q.enqueue(func, *func_args, retry=Retry(max=3))
        return job

不知道这有多好，但它似乎做了我现在想要的