QueueManager.py 文件源码

def Queue(self, queue_type="python_queue", name=None, **kwargs): #???????????
        if queue_type not in ["python_queue", "redis_queue"]: #????
            raise Exception(queue_type + " wrong")
        if queue_type == "redis_queue" and redis_enable == False:
            raise RedisImportException

        if name in self.queue_dict.keys(): #???????
            return self.queue_dict[name]
        else: #????????
            if not name: #???name?????????
                max_name_id = 0
                if self.queue_name_counter.has_key(queue_type):
                    name = queue_type + str(self.queue_name_counter[queue_type] + 1)
                    self.queue_name_counter[queue_type] += 1
                else:
                    name = queue_type + "0"
                    self.queue_name_counter[queue_type] = 0

            #???????????
            if queue_type == "python_queue":
                queue = PythonQueue(name, **kwargs)
            elif queue_type == "redis_queue":
                queue = RedisQ(name, **kwargs)
            self.queue_dict[name] = queue
            return queue