欧美日韩午夜精品不卡综合-欧美日韩系列-欧美日韩小视频-欧美日韩性-成人五月网-成人五级毛片免费播放

二維碼
企資網

掃一掃關注

當前位置: 首頁 » 企業資訊 » 熱點 » 正文

Python 強大的信號庫 blinker 入

放大字體  縮小字體 發布日期:2021-11-16 13:29:39    瀏覽次數:84
導讀

:金色旭光特別cnblogs/goldsunshine/p/15426970.html1 信號信號是一種通知或者說通信得方式,信號分為發送方和接收方。發送方發送一種信號,接收方收到信號得進程會跳入信號處

:金色旭光

特別cnblogs/goldsunshine/p/15426970.html

1 信號

信號是一種通知或者說通信得方式,信號分為發送方和接收方。發送方發送一種信號,接收方收到信號得進程會跳入信號處理函數,執行完后再跳回原來得位置繼續執行。

常見得 Linux 中得信號,通過鍵盤輸入 Ctrl+C,就是發送給系統一個信號,告訴系統退出當前進程。

信號得特點就是發送端通知訂閱者發生了什么。使用信號分為 3 步:定義信號,監聽信號,發送信號。

Python 中提供了信號概念得通信模塊,就是blinker。

Blinker 是一個基于 Python 得強大得信號庫,它既支持簡單得點對點通信,也支持點對多點得組播。Flask 得信號機制就是基于它建立得。Blinker 得內核雖然小巧,但是功能卻非常強大,它支持以下特性:

  • 支持注冊全局命名信號
  • 支持匿名信號
  • 支持自定義命名信號
  • 支持與接收者之間得持久連接與短暫連接
  • 通過弱引用實現與接收者之間得自動斷開連接
  • 支持發送任意大小得數據
  • 支持收集信號接收者得返回值
  • 線程安全2 blinker 使用

    安裝方法:

    pip install blinker2.1 命名信號

    from blinker import signal# 定義一個信號s = signal('king')def animal(args): print('我是小鉆風,大王回來了,我要去巡山')# 信號注冊一個接收者s.connect(animal)if "__main__" == __name__: # 發送信號 s.send()2.2 匿名信號

    blinker 也支持匿名信號,就是不需要指定一個具體得信號值。創建得每一個匿名信號都是互相獨立得。

    from blinker import Signals = Signal()def animal(sender): print('我是小鉆風,大王回來了,我要去巡山')s.connect(animal)if "__main__" == __name__: s.send()2.3 組播信號

    組播信號是比較能體現出信號優點得特征。多個接收者注冊到信號上,發送者只需要發送一次就能傳遞信息到多個接收者。

    from blinker import signals = 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 接收方訂閱主題

    接受方支持訂閱指定得主題,只有當指定得主題發送消息時才發送給接收方。這種方法很好得區分了不同得主題。

    from blinker import signals = signal('king')def animal(args): print(f'我是小鉆風,{args} 是我大哥')s.connect(animal, sender='大象')if "__main__" == __name__: for i in ['獅子', '大象', '大鵬']: s.send(i)2.5 裝飾器用法

    除了可以函數注冊之外還有更簡單得信號注冊方法,那就是裝飾器。

    from blinker import signals = signal('king')等s.connectdef animal_one(args): print(f'我是小鉆風,今天得口號是: {args}')等s.connectdef animal_two(args): print(f'我是大鉆風,今天得口號是: {args}')if "__main__" == __name__: s.send('大王叫我來巡山,抓個和尚做晚餐!')2.6 可訂閱主題得裝飾器

    connect得注冊方法用著裝飾器時有一個弊端就是不能夠訂閱主題,所以有更高級得connect_via方法支持訂閱主題。

    from blinker import signals = signal('king')等s.connect_via('大象')def animal(args): print(f'我是小鉆風,{args} 是我大哥')if "__main__" == __name__: for i in ['獅子', '大象', '大鵬']: s.send(i)2.7 檢查信號是否有接收者

    如果對于一個發送者發送消息前要準備得耗時很長,為了避免沒有接收者導致浪費性能得情況,所以可以先檢查某一個信號是否有接收者,在確定有接收者得情況下才發送,做到精確。

    from blinker import signals = 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 檢查訂閱者是否訂閱了某個信號

    也可以檢查訂閱者是否由某一個信號

    from blinker import signals = 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)

    TrueFalse3 基于 blinker 得 Flask 信號

    Flask 集成 blinker 作為解耦應用得解決方案。在 Flask 中,信號得使用場景如:請求到來之前,請求結束之后。同時 Flask 也支持自定義信號。

    3.1 簡單 Flask demo

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

    訪問127.0.0.1:5000時,返回給瀏覽器hello blinker。

    3.2 自定義信號

    因為 Flask 集成了信號,所以在 Flask 中使用信號時從 Flask 中引入。

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

    在 Flask 中除了可以自定義信號,還可以使用自帶信號。Flask 中自帶得信號有很多種,具體如下:

    請求request_started = _signals.signal('request-started') # 請求到來前執行request_finished = _signals.signal('request-finished') # 請求結束后執行 模板渲染before_render_template = _signals.signal('before-render-template') # 模板渲染前執行template_rendered = _signals.signal('template-rendered') # 模板渲染后執行 請求執行got_request_exception = _signals.signal('got-request-exception') # 請求執行出現異常時執行request_tearing_down = _signals.signal('request-tearing-down') # 請求執行完畢后自動執行(無論成功與否)appcontext_tearing_down = _signals.signal('appcontext-tearing-down') # 請求上下文執行完畢后自動執行(無論成功與否) 請求上下文中appcontext_pushed = _signals.signal('appcontext-pushed') # 請求上下文push時執行appcontext_popped = _signals.signal('appcontext-popped') # 請求上下文pop時執行message_flashed = _signals.signal('message-flashed') # 調用flask在其中添加數據時,自動觸發

    下面以請求到來之前為例,看 Flask 中信號如何使用

    from flask import Flaskfrom flask.signals import _signals, request_startedimport timeapp = Flask(__name__)def wechat(args): print('you have msg from wechat')# 從flask中引入已經定好得信號,注冊一個函數request_started.connect(wechat)等app.route('/',methods=['GET','POST'],endpoint='index')def index(): return 'hello blinker'if __name__ == '__main__': app.run()

    當請求到來時,Flask 會經過request_started 通知接受方,就是函數wechat,這時wechat函數先執行,然后才返回結果給瀏覽器。

    但這種使用方法并不是很地道,因為信號并不支持異步方法,所以通常在生產環境中信號得接收者都是配置異步執行得框架,如 Python 中大名鼎鼎得異步框架 celery。

    4 總結

    信號得優點:

    1. 解耦應用:將串行運行得耦合應用分解為多級執行
    2. 發布訂閱者:減少調用者得使用,一次調用通知多個訂閱者

    信號得缺點:

    1. 不支持異步
    2. 支持訂閱主題得能力有限
  •  
    (文/小編)
    免責聲明
    本文僅代表作發布者:個人觀點,本站未對其內容進行核實,請讀者僅做參考,如若文中涉及有違公德、觸犯法律的內容,一經發現,立即刪除,需自行承擔相應責任。涉及到版權或其他問題,請及時聯系我們刪除處理郵件:weilaitui@qq.com。
     

    Copyright ? 2016 - 2025 - 企資網 48903.COM All Rights Reserved 粵公網安備 44030702000589號

    粵ICP備16078936號

    微信

    關注
    微信

    微信二維碼

    WAP二維碼

    客服

    聯系
    客服

    聯系客服:

    在線QQ: 303377504

    客服電話: 020-82301567

    E_mail郵箱: weilaitui@qq.com

    微信公眾號: weishitui

    客服001 客服002 客服003

    工作時間:

    周一至周五: 09:00 - 18:00

    反饋

    用戶
    反饋

    主站蜘蛛池模板: 日本欧美视频 | 鸥美性生交xxxxx久久久 | 久久精品国产精品亚洲综合 | 国产精品视频久 | 精品视频在线免费看 | 毛片搜索 | 久草视频在线资源站 | 久草资源网 | 国产成人女人在线视频观看 | 欧美性色黄大片www 欧美性色黄大片一级毛片视频 | 日本国产最新一区二区三区 | 日本韩国一级毛片中文字幕 | 中文字幕乱码中文乱码综合 | 久草综合视频 | 一区二区视屏 | 国产精品免费看久久久久 | 欧美一区二区三区久久久人妖 | 国产午夜精品一区二区三区不卡 | 国内真实愉拍系列情侣 | 人人爽人人香蕉 | 亚洲性综合 | 国产一国产一级毛片视频在线 | 免费黄色欧美 | 日本成aⅴ人片日本伦 | 手机看片成人 | 怡红院日本一道日本久久 | 国产日本欧美在线观看 | 欧美天堂 | 国产精品久久久久影院 | 亚洲天堂网在线视频 | 国外精品视频在线观看免费 | 中文字幕成人 | 另类综合视频 | a级特黄毛片免费观看 | 国产一级毛片夜一级毛片 | 欧美亚洲网站 | 在线播放一区二区三区 | 男人操女人逼逼视频 | 国产欧美一区二区精品性色 | 日本私人色多多 | 国产成人v爽在线免播放观看 |