python实现带有优先级的消息队列

Python中可以使用`heapq`模块来实现带有优先级的消息队列。`heapq`模块提供了一些操作堆的函数，可以用来实现优先级队列，具体实现如下：

import heapq

# 定义一个空的优先级队列
q = []

# 入队操作，每个元素为一个tuple，第一个元素为优先级，第二个元素为消息内容
heapq.heappush(q, (2, 'message 2'))
heapq.heappush(q, (3, 'message 3'))
heapq.heappush(q, (1, 'message 1'))

# 出队操作会按照优先级从小到大依次弹出元素
message = heapq.heappop(q)  # 输出(1, 'message 1')
message = heapq.heappop(q)  # 输出(2, 'message 2')
message = heapq.heappop(q)  # 输出(3, 'message 3')

在以上代码中，我们通过`heapq.heappush()`方法把元素加入队列，每个元素为一个tuple，第一个元素为优先级，第二个元素为消息内容。`heapq`会按照tuple的第一个元素（即优先级）排序，因此在出队操作时，会按照优先级从小到大依次弹出元素。

需要注意的是，以上代码中的优先级越小，表示该元素的优先级越高。如果要实现优先级越大，表示该元素的优先级越高，可以在加入队列时将优先级取相反数，例如：

import heapq

# 定义一个空的优先级队列
q = []

# 入队操作，每个元素为一个tuple，第一个元素为优先级，第二个元素为消息内容
heapq.heappush(q, (-2, 'message 2'))
heapq.heappush(q, (-3, 'message 3'))
heapq.heappush(q, (-1, 'message 1'))

# 出队操作会按照优先级从大到小依次弹出元素
message = heapq.heappop(q)  # 输出(-3, 'message 3')
message = heapq.heappop(q)  # 输出(-2, 'message 2')
message = heapq.heappop(q)  # 输出(-1, 'message 1')

以上代码中，我们在加入队列时将优先级取相反数，这样可以实现优先级越大，表示该元素的优先级越高。