Pythons leistungsstarke Signalbibliothek: Blinker

1. Signal

Hallo zusammen, ich bin Laobiao~

Signal ist eine Art der Benachrichtigung oder Kommunikation. Das Signal ist in Sender und Empfänger unterteilt. Der Sender sendet ein Signal, und der Prozess des Empfängers, der das Signal empfängt, springt in die Signalverarbeitungsfunktion. Nach der Ausführung springt er zur ursprünglichen Position zurück, um die Ausführung fortzusetzen.

Ein gängiges Signal unter Linux, die Eingabe von Strg+C über die Tastatur, besteht darin, ein Signal an das System zu senden, um das System anzuweisen, den aktuellen Prozess zu beenden.

Das Merkmal eines Signals ist, dass der Absender den Abonnenten darüber informiert, was passiert ist. Die Verwendung von Signalen ist in drei Schritte unterteilt: Signale definieren, Signale überwachen und Signale senden.

Das Kommunikationsmodul, das das Signalkonzept in Python bereitstellt, ist Blinker.

Blinker ist eine leistungsstarke Signalbibliothek auf Python-Basis, die sowohl einfache Punkt-zu-Punkt-Kommunikation als auch Punkt-zu-Multipunkt-Multicast unterstützt. Darauf basiert der Signalmechanismus von Flask. Obwohl der Kernel von Blinker klein ist, ist er sehr leistungsstark. Er unterstützt die folgenden Funktionen:

• Unterstützt die Registrierung globaler benannter Signale
• Unterstützt anonyme Signale
• Unterstützt benutzerdefinierte benannte Signale
• Unterstützt dauerhafte und vorübergehende Verbindungen mit Empfängerverbindungen
• Trennt die Verbindung zum Empfänger automatisch bei schwachen Referenzen.
• Unterstützt das Senden von Daten beliebiger Größe.
• Unterstützt das Sammeln des Rückgabewerts des Signalempfängers.
• Thread-Sicherheit.

2. Blinker-Installationsmethode mit

:

pip install blinker

2.1 Benanntes Signal

from blinker import signal
# 定义一个信号
s = signal('king')
def animal(args):
print('我是小钻风，大王回来了，我要去巡山')
# 信号注册一个接收者
s.connect(animal)
if "__main__" == __name__:
# 发送信号
s.send()

2.2 Anonymes Signal

blinker unterstützt auch anonyme Signale, d. h. es ist nicht erforderlich, einen bestimmten Signalwert anzugeben. Jedes erzeugte anonyme Signal ist unabhängig voneinander.

from blinker import Signal
s = Signal()
def animal(sender):
print('我是小钻风，大王回来了，我要去巡山')
s.connect(animal)
if "__main__" == __name__:
s.send()

2.3 Multicast-Signal

Multicast-Signal ist eine Eigenschaft, die die Vorteile von Signalen besser widerspiegeln kann. Für das Signal sind mehrere Empfänger registriert, und der Sender muss nur einmal senden, um Informationen an mehrere Empfänger zu übermitteln.

from blinker import signal
s = signal('king')
def animal_one(args):
print(f'我是小钻风，今天的口号是: {args}')
def animal_two(args):
print(f'我是大钻风，今天的口号是: {args}')
s.connect(animal_one)
s.connect(animal_two)
if "__main__" == __name__:
s.send('大王叫我来巡山，抓个和尚做晚餐！')

2.4 Der Empfänger abonniert das Thema

Der Empfänger unterstützt das Abonnieren des angegebenen Themas und nur wenn das angegebene Thema eine Nachricht sendet, wird diese an den Empfänger gesendet. Diese Methode unterscheidet verschiedene Themen gut.

from blinker import signal
s = signal('king')
def animal(args):
print(f'我是小钻风，{args} 是我大哥')
s.connect(animal, sender='大象')
if "__main__" == __name__:
for i in ['狮子', '大象', '大鹏']:
s.send(i)

2.5 Verwendung von Decorators

Zusätzlich zur Funktionsregistrierung gibt es eine einfachere Signalregistrierungsmethode, nämlich den Decorator.

from blinker import signal
s = signal('king')
@s.connect
def animal_one(args):
print(f'我是小钻风，今天的口号是: {args}')
@s.connect
def animal_two(args):
print(f'我是大钻风，今天的口号是: {args}')
if "__main__" == __name__:
s.send('大王叫我来巡山，抓个和尚做晚餐！')

2.6 Decorator, der Themen abonnieren kann

Die Registrierungsmethode von Connect hat bei der Verwendung von Decorators den Nachteil, dass sie keine Themen abonnieren kann. Daher gibt es eine erweiterte connect_via-Methode, die das Abonnieren von Themen unterstützt.

from blinker import signal
s = signal('king')
@s.connect_via('大象')
def animal(args):
print(f'我是小钻风，{args} 是我大哥')
if "__main__" == __name__:
for i in ['狮子', '大象', '大鹏']:
s.send(i)

2.7 Überprüfen Sie, ob das Signal einen Empfänger hat

Wenn es lange dauert, bis sich ein Absender vorbereitet, bevor er eine Nachricht sendet, können Sie zunächst prüfen, ob ein Signal vorhanden ist, um die Leistungsverschwendung zu vermeiden, die durch keinen Empfänger verursacht wird Wenn Sie einen Empfänger angeben, senden Sie ihn nur, wenn bestätigt ist, dass es einen Empfänger gibt, und achten Sie auf Genauigkeit.

from blinker import signal
s = signal('king')
q = signal('queue')
def animal(sender):
print('我是小钻风，大王回来了，我要去巡山')
s.connect(animal)
if "__main__" == __name__:
res = s.receivers
print(res)
if res:
s.send()
res = q.receivers
print(res)
if res:
q.send()
else:
print("孩儿们都出去巡山了")

{4511880240: <weakref at 0x10d02ae80; to 'function' at 0x10cedd430 (animal)>}
我是小钻风，大王回来了，我要去巡山
{}
孩儿们都出去巡山了

2.8 Überprüfen Sie, ob der Teilnehmer ein bestimmtes Signal abonniert hat . In Flask sind die Verwendungsszenarien von Signalen wie folgt: vor dem Eintreffen der Anfrage und nach dem Ende der Anfrage. Gleichzeitig unterstützt Flask auch benutzerdefinierte Signale.

3.1 Einfache Flask-Demo

from blinker import signal
s = signal('king')
q = signal('queue')
def animal(sender):
print('我是小钻风，大王回来了，我要去巡山')
s.connect(animal)
if "__main__" == __name__:
res = s.has_receivers_for(animal)
print(res)
res = q.has_receivers_for(animal)
print(res)

Wenn Sie auf 127.0.0.1:5000 zugreifen, geben Sie den Hallo-Blinker an den Browser zurück.

3.2 Benutzerdefinierte Signale

Da Flask Signale integriert, werden diese aus Flask importiert, wenn Signale in Flask verwendet werden.

True
False

3.3 Flasks eigenes Signal

Zusätzlich zum Anpassen von Signalen können Sie auch integrierte Signale in Flask verwenden. Es gibt viele Arten von Signalen, die mit Flask geliefert werden, wie folgt:

from flask import Flask
app = Flask(__name__)
@app.route('/',methods=['GET','POST'],endpoint='index')
def index():
return 'hello blinker'
if __name__ == '__main__':
app.run()

Das Folgende ist ein Beispiel dafür, wie Signale in Flask verwendet werden, bevor die Anfrage eintrifft.

from flask import Flask
from flask.signals import _signals
app = Flask(__name__)
s = _signals.singal('msg')
def QQ(args):
print('you have msg from QQ')
s.connect(QQ)
@app.route('/',methods=['GET','POST'],endpoint='index')
def index():
s.send()
return 'hello blinker'
if __name__ == '__main__':
app.run()

Wenn eine Anfrage eingeht, benachrichtigt Flask den Empfänger über request_started ist die Funktion Wechat. Zu diesem Zeitpunkt wird zuerst die Wechat-Funktion ausgeführt und dann das Ergebnis an den Browser zurückgegeben.

Aber diese Verwendungsmethode ist nicht sehr authentisch, da Signale keine asynchronen Methoden unterstützen. Daher sind die Empfänger von Signalen in Produktionsumgebungen normalerweise Frameworks, die für die asynchrone Ausführung konfiguriert sind, wie beispielsweise das berühmte asynchrone Framework Sellerie in Python.

4. Zusammenfassung der Vorteile von

-Signalen:

1. Entkoppelte Anwendungen: Zerlegen Sie seriell laufende gekoppelte Anwendungen in mehrstufige Ausführungen
2. Abonnenten veröffentlichen: Reduzieren Sie den Einsatz von Anrufern und benachrichtigen Sie mehrere Abonnenten mit einem Anruf

Nachteile des Signals:

1. Unterstützt nicht asynchron
2. Begrenzte Möglichkeit, Themenabonnements zu unterstützen

Jedes Like, jeder Aufruf, jeder Kommentar, jeder Retweet von Ihnen ist mir sehr wichtig, vielen Dank für Ihre Unterstützung.

Okay, bis zum nächsten Mal. Ich liebe Katzen, Technologie und Sisis alte Cousine noch mehr

Das obige ist der detaillierte Inhalt vonPythons leistungsstarke Signalbibliothek: Blinker. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!