La file d'attente de vs JoinableQueue en Python

En Python tout en utilisant le multitraitement module il existe 2 types de files d'attente:

  • File d'attente
  • JoinableQueue.

Quelle est la différence entre eux?

File d'attente

from multiprocessing import Queue
q = Queue()
q.put(item) # Put an item on the queue
item = q.get() # Get an item from the queue

JoinableQueue

from multiprocessing import JoinableQueue
q = JoinableQueue()
q.task_done() # Signal task completion
q.join() # Wait for completion

OriginalL'auteur axcelenator | 2015-07-05

  1. 18

    JoinableQueue a des méthodes join() et task_done(), qui File n'a pas.

    classe de multitraitement.La file d'attente( [maxsize] )

    Renvoie à un processus partagé de la file d'attente mis en œuvre à l'aide d'un tuyau et d'un peu d'écluses/sémaphores. Lorsqu'un processus d'abord un élément dans la file d'attente d'un chargeur de fil est mis en route et les transferts d'objets à partir d'un tampon dans le tuyau.

    L'habitude de la File d'attente.Vide et la File d'attente.Plein d'exceptions à partir de la bibliothèque standard de la File d'attente du module sont soulevées pour signaler un dépassement de délai.

    File d'attente implémente toutes les méthodes de File d'attente.La file d'attente, sauf pour task_done() et join().

    classe de multitraitement.JoinableQueue( [maxsize] )

    JoinableQueue, une File d'attente sous-classe, est une file d'attente qui, de plus, a task_done() et join() méthodes.

    task_done()

    Indiquer qu'un anciennement mis en file d'attente de la tâche est terminée. Utilisé par la file d'attente à la consommation de threads. Pour chaque get() utilisé pour récupérer une tâche, un appel ultérieur à task_done() indique la file d'attente que le traitement de la tâche est terminée.

    Si un join() bloque actuellement, il reprendra lorsque tous les objets ont été traités (ce qui signifie qu'un task_done() l'appel a été reçu pour chaque élément qui avait été mis (en) dans la file d'attente).

    Soulève un ValueError si on le plus de fois qu'il y avait des éléments placés dans la file d'attente.

    join()

    Bloc jusqu'à ce que tous les éléments dans la file d'attente ont été reçu et traité.

    Le nombre de tâches inachevées va chaque fois qu'un élément est ajouté à la file d'attente. Le comte va vers le bas à chaque fois qu'un thread consommateur appels task_done() pour indiquer que l'élément a été récupérée et tous les travaux sur qu'il est complet. Lorsque le nombre de tâches inachevées tombe à zéro, join() débloque.

    Si vous utilisez JoinableQueue ensuite, vous devez appeler JoinableQueue.task_done() pour chaque tâche retiré de la file d'attente ou bien le sémaphore utilisé pour compter le nombre de tâches inachevées peuvent, éventuellement, de dépassement, de lever une exception.

    Savez-vous ce que la valeur de débordement est, ou comment le trouver? La documentation n'est pas dire.
    D'ailleurs en citant la documentation - ce qui fait cette réponse apporter ? Un exemple et une certaine interprétation serait sympa

    OriginalL'auteur fferri