Python中如何实现消息超时队列

2023-04-11 00:00:00 队列 超时 如何实现

实现一个消息超时队列，可以使用Python的queue模块。步骤如下：

  1. 导入queue模块。
import queue
  1. 创建一个消息队列对象，并设置一个超时时间。
q = queue.Queue(timeout=5)
  1. 使用put方法将消息加入队列。
q.put('pidancode.com')
q.put('皮蛋编程')
  1. 使用get方法从队列中取出消息。如果在设置的超时时间内没有消息，则会抛出queue.Empty异常。
try:
    msg = q.get()
    print(msg)
except queue.Empty:
    print('队列为空')

完整代码示例：

import queue

q = queue.Queue(timeout=5)

q.put('pidancode.com')
q.put('皮蛋编程')

try:
    msg = q.get()
    print(msg)
except queue.Empty:
    print('队列为空')

输出：

pidancode.com

相关文章