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:
:
pip install blinker
from blinker import signal # 定义一个信号 s = signal('king') def animal(args): print('我是小钻风,大王回来了,我要去巡山') # 信号注册一个接收者 s.connect(animal) if "__main__" == __name__: # 发送信号 s.send()
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()
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('大王叫我来巡山,抓个和尚做晚餐!')
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)
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('大王叫我来巡山,抓个和尚做晚餐!')
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)
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)>} 我是小钻风,大王回来了,我要去巡山 {} 孩儿们都出去巡山了
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)
True False
from flask import Flask app = Flask(__name__) @app.route('/',methods=['GET','POST'],endpoint='index') def index(): return 'hello blinker' if __name__ == '__main__': app.run()
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()
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.
-Signalen:
Nachteile des Signals:
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!