Comment puis-je effacer une file d'attente. Par exemple, j'ai des données dans une file d'attente, mais pour une raison quelconque, je n'ai pas besoin des données existantes, et je veux juste effacer la file d'attente.
Y a-t-il un moyen ? Cela fonctionnera-t-il ?
oldQueue = Queue.Queue()
@DanD. Corrigez-moi si je me trompe, mais il semble que ce soit en fait un mauvais idée pour moi. .mutex y .queue semble être non documenté et si je ne me trompe pas, l'utilisation de q.mutex serait impasse si vous faites quelque chose comme même q.get_nowait à l'intérieur de son bloc.
@Jean-BernardJansen : Il n'est pas automatiquement threadsafe si vous manipulez directement ses composants internes, et q.queue.clear() c'est de bousiller les internes directement.
Vous ne pouvez pas vider la file d'attente, car chaque mise en place ajoute également le membre unfinished_tasks. La méthode join dépend de cette valeur. Et all_tasks_done doit aussi être notifié.
q.mutex.acquire()
q.queue.clear()
q.all_tasks_done.notify_all()
q.unfinished_tasks = 0
q.mutex.release()ou de manière décente, utiliser la paire get et task_done pour effacer les tâches en toute sécurité.
while not q.empty():
try:
q.get(False)
except Empty:
continue
q.task_done()ou simplement créer une nouvelle file d'attente et supprimer l'ancienne.
Soyez prudent avec cette méthode également. Le site docs Notez que "si empty() renvoie False, cela ne garantit pas qu'un appel ultérieur à get() ne bloquera pas".
La deuxième méthode (la méthode "décente") semble être la plus sûre et la plus élégante, et n'utilise que l'API publique et documentée. Quelqu'un peut-il confirmer ?
Cela semble faire l'affaire pour moi. Les commentaires et les ajouts sont les bienvenus au cas où j'aurais oublié quelque chose d'important.
class Queue(queue.Queue):
'''
A custom queue subclass that provides a :meth:`clear` method.
'''
def clear(self):
'''
Clears all items from the queue.
'''
with self.mutex:
unfinished = self.unfinished_tasks - len(self.queue)
if unfinished <= 0:
if unfinished < 0:
raise ValueError('task_done() called too many times')
self.all_tasks_done.notify_all()
self.unfinished_tasks = unfinished
self.queue.clear()
self.not_full.notify_all() Prograide est une communauté de développeurs qui cherche à élargir la connaissance de la programmation au-delà de l'anglais.
Pour cela nous avons les plus grands doutes résolus en français et vous pouvez aussi poser vos propres questions ou résoudre celles des autres.
4 votes
Si vous lisez la documentation, elle vous renvoie au module Queue's dernière source et là vous pouvez voir que la représentation interne d'une file FIFO est un
deque. Dans la documentation dedequevous remarquerez qu'il y a unclear()ce qui est ce que vous voulez. Vous voudrez probablement aussi entourer cet appel d'une méthode de typeq.mutex.acquire()yq.mutex.release()comme le fait le reste du code autour de telles opérations pour le rendre sûr.