如何从队列中间移除一个元素？

Question

在Python中，有没有办法在多线程的情况下，移除一个项目并让队列自动重新排序呢？

我有一些用户排队在一个队列里，但当要处理这个用户的时候，如果用户断开了连接，这就会出现问题。

有没有什么办法可以解决这个问题呢？

谢谢！

Answer 1

这是可能的。你可以通过访问队列中的元素来删除特定的项目。remove 是 Queue.queue 中的一个方法。

>>> from queue import Queue
>>> f = Queue(3)
>>> f.put(4)
>>> f.put(3)
>>> f.put(2)
>>> f.queue
deque([4,3,2])
>>> f.queue.__dir
['__new__', '__repr__', '__hash__', '__getattribute__', '__lt__', '__le__', '__eq__', '__ne__', '__gt__', '__ge__', '__iter__', '__init__', '__len__', '__add__', '__mul__', '__rmul__', '__getitem__', '__setitem__', '__delitem__', '__contains__', '__iadd__', '__imul__', 'append', 'appendleft', 'clear', '__copy__', 'copy', 'count', 'extend', 'extendleft', 'index', 'insert', 'pop', 'popleft', '__reduce__', 'remove', '__reversed__', 'reverse', 'rotate', '__sizeof__', '__class_getitem__', 'maxlen', '__doc__', '__str__', '__setattr__', '__delattr__', '__reduce_ex__', '__getstate__', '__subclasshook__', '__init_subclass__', '__format__', '__dir__', '__class__']
>>> f.queue.remove(3)
>>> f.queue
deque([4,2])

Answer 2

队列对象不支持随机访问，也就是说你不能随便取出队列里某个位置的元素。不过，你可以在其他地方保存对队列中对象的引用，并把它们标记为过期。当从队列中读取对象时，消费者可以检查这个对象是否过期，如果过期了，就把它丢掉，再重新读取。

你可能还会觉得 优先队列 类很有用。在这个队列里，你可以放入 (优先级, 消息)，而不是单纯的 消息。这样，优先级值最低的数据总是会是下一个被读取的对象。虽然这本身不能解决你的问题，但它可能会让你有办法优先处理最旧的请求或者类似的事情。