有没有一种方法可以检查Python中的优先级队列中是否存在优先级？

我的理解是，您的最终目标是将具有相同优先级的任务放在列表中并一起返回。所以：

如果要查看queue.PriorityQueue（我做过的）代码，您会发现它基于模块的heappush和heappop方法，该heapq模块实现了堆队列算法。参见heapq。如果您在此页面上进一步浏览，它们甚至显示了如何使用heapq来实现优先级队列。此实现比您需要的实现要复杂一些，因为它支持更改已添加任务的优先级的功能，并且不能完全按照您想要的优先级处理多个任务。但是这些更改很容易实现：

from heapq import heappush, heappop

class PriorityQueue:
    def __init__(self):
        self._pq = [] # list of entries arranged in a heap
        self._priority_finder = {} # mapping of priority to entries

    def add_task(self, task, priority=0):
        'Add a new task'
        # any tasks with this priority?
        entry = self._priority_finder.get(priority)
        if entry:
            entry[1].append(task)
        else:
            entry = [priority, [task]]
            self._priority_finder[priority] = entry
            heappush(self._pq, entry)

    def pop_task(self):
        'Remove and return the lowest priority tasks. Raise KeyError if empty.'
        if not self._pq:
            raise KeyError('pop from an empty priority queue')
        priority, tasks = heappop(self._pq)
        del self._priority_finder[priority]
        return priority, tasks

    def __bool__(self):
        'return True if any tasks on the queue'
        return True if self._pq else False

pq = PriorityQueue()
pq.add_task('a', 4) # task 'a' with priority 4
pq.add_task('b', 2)
pq.add_task('c', 4)
pq.add_task('d', 2)
pq.add_task('e', 1)
while pq:
    print(pq.pop_task())

印刷品：

(1, ['e'])
(2, ['b', 'd'])
(4, ['a', 'c'])