Inhaltsverzeichnis
3 verschiedene Warteschlangenklassen
Gemeinsame Methoden
Heim Backend-Entwicklung Python-Tutorial Verwendung des Warteschlangenmoduls (Warteschlange) unter Python-Thread (mit Beispielen)

Verwendung des Warteschlangenmoduls (Warteschlange) unter Python-Thread (mit Beispielen)

Sep 11, 2018 pm 04:48 PM
python

In diesem Artikel geht es um die Verwendung des Warteschlangenmoduls unter Python-Threads. Ich hoffe, dass es für Freunde hilfreich ist.

Das Warteschlangenmodul implementiert verschiedene [Multi-Produzenten-Multi-Verbraucher]-Warteschlangen. Kann zum sicheren Austausch von Informationen zwischen mehreren Ausführungsthreads verwendet werden.

Das Warteschlangenmodul definiert 3 verschiedene Warteschlangenklassen.

3 verschiedene Warteschlangenklassen

q=Queue(maxsize): Erstellen Sie eine FIFO-Warteschlange (First-In, First-Out, First-In, First-Out). maxsize ist die maximale Anzahl von Elementen, die in die Warteschlange gestellt werden können.
Wenn der Parameter maxsize weggelassen oder auf 0 gesetzt wird, ist die Warteschlangengröße unendlich.

q=LifoQueue(maxsize): Erstellen Sie eine LIFO-Warteschlange (Last-In, First-Out, Last-In, First-Out).

q=PriorityQueue(maxsize): Erstellen Sie eine Prioritätswarteschlange, in der Elemente von niedriger bis hoher Priorität angeordnet werden.
Bei Verwendung dieser Art von Warteschlange sollte das Element ein Tupel der Form (Priorität, Daten) sein, wobei Priorität eine Zahl ist, die die Priorität identifiziert.

Gemeinsame Methoden

q.size(): Gibt die korrekte Größe der Warteschlange zurück. Da möglicherweise andere Threads diese Warteschlange aktualisieren, ist die von dieser Methode zurückgegebene Zahl unzuverlässig.

q.empty(): Wenn die Warteschlange leer ist, geben Sie True zurück, andernfalls geben Sie False zurück.

q.full(): Wenn die Warteschlange voll ist, geben Sie True zurück, andernfalls geben Sie False zurück.

q.put(item, block, timeout): Element in die Warteschlange stellen.
Wenn die Blockierung auf „True“ (Standardwert) eingestellt ist, wird der Anrufer blockiert, bis eine verfügbare freie Position in der Warteschlange erscheint.
Wenn block auf False gesetzt ist, löst diese Methode eine Full-Ausnahme aus, wenn die Warteschlange voll ist.

q.put_nowait(item): Äquivalent zu q.put(item,False)

q.get(block, timeout): Löschen Sie ein Element aus der Warteschlange und geben Sie das Element zurück.
Wenn „Block“ auf „True“ (Standardwert) gesetzt ist, blockiert der Anrufer, bis in der Warteschlange eine freie Zeit verfügbar ist.
Wenn der Block auf „False“ gesetzt ist, wird eine Empty-Ausnahme ausgelöst, wenn die Warteschlange leer ist.
timeout stellt einen optionalen Timeout-Wert in Sekunden bereit. Bei einer Zeitüberschreitung wird eine Empty-Ausnahme ausgelöst.

q.get_nowait(): Äquivalent zu get(0)

q.task_done(): Wird von Verbrauchern von Daten in der Warteschlange verwendet, um anzuzeigen, dass die Verarbeitung des Elements beendet wurde. Wenn Sie diese Methode verwenden, sollte sie für jedes aus der Warteschlange entfernte Element einmal aufgerufen werden.

q.join(): Blockiert, bis alle Elemente in der Warteschlange entfernt und verarbeitet wurden. Diese Methode kehrt direkt zurück, sobald die Methode q.task_done() einmal für jedes Element in der Warteschlange aufgerufen wurde.

Beispiel:

Die Verwendung von Warteschlangen kann Multithread-Programme im Allgemeinen vereinfachen. Beispielsweise können Sie gemeinsam genutzte Warteschlangen verwenden, um Threads miteinander zu verbinden, ohne sich zum Schutz auf Sperren verlassen zu müssen.

Bei diesem Modell fungiert der Worker-Thread im Allgemeinen als Datenkonsument.

from threading import Thread
from queue import Queue
class WorkerThread(Thread):
    def __init__(self,*args,**kwargs):
        Thread.__init__(self,*args,**kwargs)
        self.input_queue=Queue()

    def send(self,item):
        self.input_queue.put(item)
    def close(self):
        self.input_queue.put(None)
        self.input_queue.join()
    def run(self):
        while True:
            item=self.input_queue.get()
            if item is None:
                break
            #实际开发中,此处应该使用有用的工作代替
            print(item)
            self.input_queue.task_done()
        #完成,指示收到和返回哨兵
        self.input_queue.task_done()
        return

if __name__=="__main__":
    w=WorkerThread()
    w.start()
    w.send("php")
    w.send("中")
    w.send("文")
    w.send("网")
    w.close()
Nach dem Login kopieren

Laufergebnisse:

php
中
文
网
Nach dem Login kopieren

Verwandte Empfehlungen:

Umfassende Analyse des Prinzips der Python-Thread-Prioritätswarteschlange (Warteschlange)

Thread-Synchronisierungsmethode mit Warteschlange und Bedingung in Python

Das obige ist der detaillierte Inhalt vonVerwendung des Warteschlangenmoduls (Warteschlange) unter Python-Thread (mit Beispielen). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heiße KI -Werkzeuge

Undresser.AI Undress

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool

Undress AI Tool

Ausziehbilder kostenlos

Clothoff.io

Clothoff.io

KI-Kleiderentferner

AI Hentai Generator

AI Hentai Generator

Erstellen Sie kostenlos Ai Hentai.

Heißer Artikel

R.E.P.O. Energiekristalle erklärten und was sie tun (gelber Kristall)
2 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Repo: Wie man Teamkollegen wiederbelebt
4 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Abenteuer: Wie man riesige Samen bekommt
4 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

Heiße Werkzeuge

Notepad++7.3.1

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Wie löste ich das Problem der Berechtigungen beim Betrachten der Python -Version in Linux Terminal? Wie löste ich das Problem der Berechtigungen beim Betrachten der Python -Version in Linux Terminal? Apr 01, 2025 pm 05:09 PM

Lösung für Erlaubnisprobleme beim Betrachten der Python -Version in Linux Terminal Wenn Sie versuchen, die Python -Version in Linux Terminal anzuzeigen, geben Sie Python ein ...

Wie kann ich die gesamte Spalte eines Datenrahmens effizient in einen anderen Datenrahmen mit verschiedenen Strukturen in Python kopieren? Wie kann ich die gesamte Spalte eines Datenrahmens effizient in einen anderen Datenrahmen mit verschiedenen Strukturen in Python kopieren? Apr 01, 2025 pm 11:15 PM

Bei der Verwendung von Pythons Pandas -Bibliothek ist das Kopieren von ganzen Spalten zwischen zwei Datenrahmen mit unterschiedlichen Strukturen ein häufiges Problem. Angenommen, wir haben zwei Daten ...

Können Python -Parameteranmerkungen Zeichenfolgen verwenden? Können Python -Parameteranmerkungen Zeichenfolgen verwenden? Apr 01, 2025 pm 08:39 PM

Alternative Verwendung von Python -Parameteranmerkungen in der Python -Programmierung, Parameteranmerkungen sind eine sehr nützliche Funktion, die den Entwicklern helfen kann, Funktionen besser zu verstehen und zu verwenden ...

Python Cross-Platform Desktop-Anwendungsentwicklung: Welche GUI-Bibliothek ist die beste für Sie? Python Cross-Platform Desktop-Anwendungsentwicklung: Welche GUI-Bibliothek ist die beste für Sie? Apr 01, 2025 pm 05:24 PM

Auswahl der Python-plattformübergreifenden Desktop-Anwendungsentwicklungsbibliothek Viele Python-Entwickler möchten Desktop-Anwendungen entwickeln, die sowohl auf Windows- als auch auf Linux-Systemen ausgeführt werden können ...

Wie lösten Python -Skripte an einem bestimmten Ort die Ausgabe in Cursorposition? Wie lösten Python -Skripte an einem bestimmten Ort die Ausgabe in Cursorposition? Apr 01, 2025 pm 11:30 PM

Wie lösten Python -Skripte an einem bestimmten Ort die Ausgabe in Cursorposition? Beim Schreiben von Python -Skripten ist es üblich, die vorherige Ausgabe an die Cursorposition zu löschen ...

Warum kann mein Code nicht die von der API zurückgegebenen Daten erhalten? Wie löst ich dieses Problem? Warum kann mein Code nicht die von der API zurückgegebenen Daten erhalten? Wie löst ich dieses Problem? Apr 01, 2025 pm 08:09 PM

Warum kann mein Code nicht die von der API zurückgegebenen Daten erhalten? Bei der Programmierung stoßen wir häufig auf das Problem der Rückgabe von Nullwerten, wenn API aufruft, was nicht nur verwirrend ist ...

Wie hört Uvicorn kontinuierlich auf HTTP -Anfragen ohne Serving_forver () an? Wie hört Uvicorn kontinuierlich auf HTTP -Anfragen ohne Serving_forver () an? Apr 01, 2025 pm 10:51 PM

Wie hört Uvicorn kontinuierlich auf HTTP -Anfragen an? Uvicorn ist ein leichter Webserver, der auf ASGI basiert. Eine seiner Kernfunktionen ist es, auf HTTP -Anfragen zu hören und weiterzumachen ...

Wie erstelle ich dynamisch ein Objekt über eine Zeichenfolge und rufe seine Methoden in Python auf? Wie erstelle ich dynamisch ein Objekt über eine Zeichenfolge und rufe seine Methoden in Python auf? Apr 01, 2025 pm 11:18 PM

Wie erstellt in Python ein Objekt dynamisch über eine Zeichenfolge und ruft seine Methoden auf? Dies ist eine häufige Programmieranforderung, insbesondere wenn sie konfiguriert oder ausgeführt werden muss ...

See all articles