Multiprocessing Warteschlange Stapel bis zu max N Elemente

Question

Ich muss so viele Gegenstände wie möglich aus einer Warteschlange (bis zu N), in einer blockierenden Art und Weise zu bekommen. Beispiel:

queue.get(16) 

Sollte bis zu 16 Elemente zurückgeben, aber blockieren, wenn leer.

Answer 1

Da ist keine solche Einrichtung eingebaut, Sie müssen sie also selbst programmieren; zum Beispiel

import queue # in Python 3; Queue in Python 2 
... 
def getn(q, n): 
    result = [q.get()] # block until at least 1 
    try: # add more until `q` is empty or `n` items obtained 
     while len(result) < n: 
      result.append(q.get(block=False)) 
    except queue.Empty: 
     pass 
    return result 

tun Dann getn(queue, 16) für Ihre konzeptionellen queue.get(16).