redis_queue.py 文件源码

def __init__(self, name):
        """"""
        self.poped_name = self.POPED_FMT % (name)
        self.pushed_name = self.PUSHED_FMT % (name)
        pool = redis.ConnectionPool(host=self.HOST, port=self.PORT, db=self.DB)
        self.conn = redis.Redis(connection_=pool)