免费人成动漫在线播放r18-免费人成观看在线网-免费人成黄页在线观看日本-免费人成激情视频在线观看冫-jlzzjlzz亚洲大全-jlzzjlzz亚洲日本

二維碼
企資網(wǎng)

掃一掃關(guān)注

當前位置: 首頁 » 企資頭條 » 專題 » 正文

Python 強大的信號庫 blinker 入

放大字體  縮小字體 發(fā)布日期:2021-11-16 13:29:39    瀏覽次數(shù):55
導(dǎo)讀

感謝分享:金色旭光近日:感謝分享特別cnblogs感謝原創(chuàng)分享者/goldsunshine/p/15426970.html1 信號信號是一種通知或者說通信得方式,信號分為發(fā)送方和接收方。發(fā)送方發(fā)送一種信號,接收方收到信號得進程會跳入信號處

感謝分享:金色旭光

近日:感謝分享特別cnblogs感謝原創(chuàng)分享者/goldsunshine/p/15426970.html

1 信號

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

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

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

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

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

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

    安裝方法:

    pip install blinker2.1 命名信號

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

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

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

    組播信號是比較能體現(xiàn)出信號優(yōu)點得特征。多個接收者注冊到信號上,發(fā)送者只需要發(fā)送一次就能傳遞信息到多個接收者。

    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 接收方訂閱主題

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

    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 裝飾器用法

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

    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 檢查信號是否有接收者

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

    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 作為解耦應(yīng)用得解決方案。在 Flask 中,信號得使用場景如:請求到來之前,請求結(jié)束之后。同時 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 感謝對創(chuàng)作者的支持(args): print('you have msg from 感謝對創(chuàng)作者的支持')s.connect(感謝對創(chuàng)作者的支持)等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') # 請求到來前執(zhí)行request_finished = _signals.signal('request-finished') # 請求結(jié)束后執(zhí)行 模板渲染before_render_template = _signals.signal('before-render-template') # 模板渲染前執(zhí)行template_rendered = _signals.signal('template-rendered') # 模板渲染后執(zhí)行 請求執(zhí)行g(shù)ot_request_exception = _signals.signal('got-request-exception') # 請求執(zhí)行出現(xiàn)異常時執(zhí)行request_tearing_down = _signals.signal('request-tearing-down') # 請求執(zhí)行完畢后自動執(zhí)行(無論成功與否)appcontext_tearing_down = _signals.signal('appcontext-tearing-down') # 請求上下文執(zhí)行完畢后自動執(zhí)行(無論成功與否) 請求上下文中appcontext_pushed = _signals.signal('appcontext-pushed') # 請求上下文push時執(zhí)行appcontext_popped = _signals.signal('appcontext-popped') # 請求上下文pop時執(zhí)行message_flashed = _signals.signal('message-flashed') # 調(diào)用flask在其中添加數(shù)據(jù)時,自動觸發(fā)

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

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

    當請求到來時,F(xiàn)lask 會經(jīng)過request_started 通知接受方,就是函數(shù)wechat,這時wechat函數(shù)先執(zhí)行,然后才返回結(jié)果給瀏覽器。

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

    4 總結(jié)

    信號得優(yōu)點:

    1. 解耦應(yīng)用:將串行運行得耦合應(yīng)用分解為多級執(zhí)行
    2. 發(fā)布訂閱者:減少調(diào)用者得使用,一次調(diào)用通知多個訂閱者

    信號得缺點:

    1. 不支持異步
    2. 支持訂閱主題得能力有限
  •  
    (文/小編)
    打賞
    免責聲明
    本文為小編推薦作品?作者: 小編。歡迎轉(zhuǎn)載,轉(zhuǎn)載請注明原文出處:http://m.bangpiao.com.cn/news/show-216383.html 。本文僅代表作者個人觀點,本站未對其內(nèi)容進行核實,請讀者僅做參考,如若文中涉及有違公德、觸犯法律的內(nèi)容,一經(jīng)發(fā)現(xiàn),立即刪除,作者需自行承擔相應(yīng)責任。涉及到版權(quán)或其他問題,請及時聯(lián)系我們郵件:weilaitui@qq.com。
     

    Copyright ? 2016 - 2023 - 企資網(wǎng) 48903.COM All Rights Reserved 粵公網(wǎng)安備 44030702000589號

    粵ICP備16078936號

    微信

    關(guān)注
    微信

    微信二維碼

    WAP二維碼

    客服

    聯(lián)系
    客服

    聯(lián)系客服:

    在線QQ: 303377504

    客服電話: 020-82301567

    E_mail郵箱: weilaitui@qq.com

    微信公眾號: weishitui

    客服001 客服002 客服003

    工作時間:

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

    反饋

    用戶
    反饋

    主站蜘蛛池模板: 国产不卡一区二区视频免费 | 日本国产最新一区二区三区 | 在线观看91精品国产hd | 视频一本大道香蕉久在线播放 | 国产欧美日韩综合精品无毒 | 小视频黄 | 2022久久国产精品免费热麻豆 | 日本3p视频在线看高清 | 国产视频精品免费 | 一级毛片成人免费看a | 青草色视频 | 国产欧美日韩精品第二区 | 日本国产美国日韩欧美mv | 欧美成人免费草草影院视频 | 欧美亚洲国产精品久久久久 | 亚洲一区欧美 | 手机在线免费毛片 | 成人高清视频免费观看 | 色哟哟www网站入口成人学校 | 乱系列h全文阅读小黄文肉 乱色美www女麻豆 | 国产一级毛片国产 | 国产大片在线播放 | 午夜影院福利社 | 国产精品丝袜 | 亚洲一区导航 | 免费二级c片在线观看a | 国产一区二区免费视频 | 亚洲国产日韩精品 | 日韩在线视频免费不卡一区 | 欧美成人三级视频 | 欧美在线观看黄色 | 最近2019好看的中文字幕免费 | 国产精品久久免费视频 | 亚州淫片aaaa视频 | 国产 日韩 欧美 综合 | 久久网页| 久久久精品2018免费观看 | 国产精品久久久香蕉 | 国产v在线在线观看羞羞答答 | 男女羞羞视频免费看 | 亚洲专区在线 |