def __init__(self, priorities):
        try:
            self.queues = collections.OrderedDict()
        except __HOLE__:
            self.queues = ordereddict.OrderedDict()
        for key in priorities:
            self.queues[key] = collections.deque()
        self.condition = threading.Condition()
        self.incomplete = []
dataset/ETHPy150Open openstack/gertty/gertty/sync.py/MultiQueue.__init__