BlockingQueue - méthodes drainTo() bloquées

Question

BlockingQueue a la méthode appelée drainTo() mais n'est pas bloquée. J'ai besoin d'une file d'attente que je veux bloquer mais aussi capable de récupérer des objets en file d'attente dans une seule méthode. Je suppose que le code ci-dessus va fonctionner, mais je suis à la recherche d'une solution élégante.

Answer 1

Vous parlez de commentaire dans le JavaDoc:

De plus, le comportement de cette opération est définie si la collection spécifiée est modifiée pendant que l'opération est en cours.

Je crois que cela fait référence à la collection list dans votre exemple:

blockingQueue.drainTo(list); 

qui signifie que vous ne pouvez pas modifier list en même temps que vous drainent de blockingQueue en list. Cependant, la file d'attente de blocage se synchronise de manière interne de sorte que lorsque drainTo est appelée, puts et (voir la remarque ci-dessous) seront bloqués. Si ce n'était pas le cas, cela ne serait pas vraiment sans danger pour les threads. Vous pouvez regarder le code source et vérifier que drainTo est thread-safe concernant la file d'attente de blocage elle-même.

Alternativement, voulez-vous dire que lorsque vous appelez drainTo que vous voulez qu'il bloque jusqu'à ce qu'au moins un objet a été ajouté à la file d'attente? Dans ce cas, vous avez peu d'autre choix que:

list.add(blockingQueue.take()); 
blockingQueue.drainTo(list); 

pour bloquer jusqu'à ce qu'un ou plusieurs éléments ont été ajoutés, puis égoutter toute la file d'attente dans la collection list.

Remarque: Depuis Java 7, un verrou séparé est utilisé pour les transactions get et puts. Les opérations de Put sont maintenant permises pendant un drainTo (et un certain nombre d'autres opérations de prise).

Answer 2

Avec l'API disponible, je ne pense pas que vous allez devenir beaucoup plus élégant. Autre que vous pouvez supprimer le test de taille.

Si vous souhaitez extraire de manière atomique une séquence contiguë d'éléments même si une autre opération de suppression coïncide, je ne crois pas que drainTo le garantisse.

Answer 3

code source:

596:  public int drainTo(Collection<? super E> c) { 
       //arg. check 
603:   lock.lock(); 
604:   try { 
608:    for (n = 0 ; n != count ; n++) { 
609:     c.add(items[n]); 
613:    } 
614:    if (n > 0) { 
618:     notFull.signalAll(); 
619:    } 
620:    return n; 
621:   } finally { 
622:    lock.unlock(); 
623:   } 
624:  } 

ArrayBlockingQueue est impatient de retourner 0. BTW, il pourrait le faire avant de prendre le verrou.

Answer 4

J'ai trouvé ce modèle utile.

List<byte[]> blobs = new ArrayList<byte[]>(); 
if (queue.drainTo(blobs, batch) == 0) { 
    blobs.add(queue.take()); 
} 

Answer 5

Si vous arrive d'utiliser Google goyave, il y a une méthode astucieuse Queues.drain().

Drains la file d'attente comme BlockingQueue.drainTo(Collection, int), mais si les demandées numElements éléments ne sont pas disponibles, il attendra les jusqu'à le délai spécifié.