成人视屏在线观看-国产99精品-国产精品1区2区-欧美一级在线观看-国产一区二区日韩-色九九九

您的位置:首頁技術文章
文章詳情頁

python 使用事件對象asyncio.Event來同步協程的操作

瀏覽:76日期:2022-07-26 13:34:09

事件對象asyncio.Event是基于threading.Event來實現的。

事件可以一個信號觸發多個協程同步工作,

例子如下:

import asyncioimport functools def set_event(event): print(’setting event in callback’) event.set() async def coro1(event): print(’coro1 waiting for event’) await event.wait() print(’coro1 triggered’) async def coro2(event): print(’coro2 waiting for event’) await event.wait() print(’coro2 triggered’) async def main(loop): # Create a shared event event = asyncio.Event() print(’event start state: {}’.format(event.is_set())) loop.call_later( 0.1, functools.partial(set_event, event) ) await asyncio.wait([coro1(event), coro2(event)]) print(’event end state: {}’.format(event.is_set())) event_loop = asyncio.get_event_loop()try: event_loop.run_until_complete(main(event_loop))finally: event_loop.close()

輸出如下:

event start state: Falsecoro2 waiting for eventcoro1 waiting for eventsetting event in callbackcoro2 triggeredcoro1 triggeredevent end state: True

補充知識: python里使用協程來創建echo客戶端

在這個例子里使用asyncio.Protocol來創建一個echo客戶端,先導入庫asyncio和logging。

接著定義發送的消息MESSAGES。

創建連接服務器的地址SERVER_ADDRESS,接著創建EchoClient類,它是繼承asyncio.Protocol。

在這個類的構造函數里,接收兩個參數messages和future,

messages是指定要發送的消息數據,future是用來通知socket接收數據完成或者服務器關閉socket的事件通知,以便事件循環知道這個協程已經完成了,就可以退出整個程序。

connection_made函數是當socket連接到服務器時調用,它就立即發送數據給服務器,數據發送完成之后發送了eof標記。

服務器收到數據和標志都回復客戶端,客戶端data_received函數接收數據,eof_received函數接收結束標記。

connection_lost函數收到服務器斷開連接。

這行代碼:

client_completed = asyncio.Future()

創建一個協程完成的觸發事件。

由于event_loop.create_connection函數只能接收一個參數,需要使用functools.partial來進行多個參數包裝成一個參數。

后面通過事件循環來運行協程。

import asyncioimport functoolsimport loggingimport sys MESSAGES = [ b’This is the message. ’, b’It will be sent ’, b’in parts.’,]SERVER_ADDRESS = (’localhost’, 10000) class EchoClient(asyncio.Protocol): def __init__(self, messages, future): super().__init__() self.messages = messages self.log = logging.getLogger(’EchoClient’) self.f = future def connection_made(self, transport): self.transport = transport self.address = transport.get_extra_info(’peername’) self.log.debug( ’connecting to {} port {}’.format(*self.address) ) # This could be transport.writelines() except that # would make it harder to show each part of the message # being sent. for msg in self.messages: transport.write(msg) self.log.debug(’sending {!r}’.format(msg)) if transport.can_write_eof(): transport.write_eof() def data_received(self, data): self.log.debug(’received {!r}’.format(data)) def eof_received(self): self.log.debug(’received EOF’) self.transport.close() if not self.f.done(): self.f.set_result(True) def connection_lost(self, exc): self.log.debug(’server closed connection’) self.transport.close() if not self.f.done(): self.f.set_result(True) super().connection_lost(exc) logging.basicConfig( level=logging.DEBUG, format=’%(name)s: %(message)s’, stream=sys.stderr,)log = logging.getLogger(’main’) event_loop = asyncio.get_event_loop() client_completed = asyncio.Future() client_factory = functools.partial( EchoClient, messages=MESSAGES, future=client_completed,)factory_coroutine = event_loop.create_connection( client_factory, *SERVER_ADDRESS,) log.debug(’waiting for client to complete’)try: event_loop.run_until_complete(factory_coroutine) event_loop.run_until_complete(client_completed)finally: log.debug(’closing event loop’) event_loop.close()

以上這篇python 使用事件對象asyncio.Event來同步協程的操作就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持好吧啦網。

標簽: Python 編程
相關文章:
主站蜘蛛池模板: 欧美成人午夜在线全部免费 | 成年性午夜免费视频网站不卡 | 亚洲国产高清视频在线观看 | 在线亚洲精品国产波多野结衣 | 成人做爰全过程免费看网站 | 国产成人免费a在线资源 | 午夜寂寞福利 | 女人十八一级毛片 | 美女色黄网站 | 亚洲国产精品专区 | 亚洲国产网址 | 一区二区网站在线观看 | 久久国产精品久久久久久久久久 | 九九色网站 | 亚洲爆爽 | 无限资源中文免费 | 成人国产精品免费视频 | 二区三区在线 | 精品国产免费第一区二区三区日韩 | 国产精品18久久久久久小说 | 亚洲 欧美 精品专区 极品 | 精品a视频 | 国产精品国产三级在线高清观看 | 成年人免费网站在线观看 | 九九九热视频 | 免费国产综合视频在线看 | 日本成a人片在线观看网址 日本成年人视频网站 | 久久爱com| 5x社区直接进入一区二区三区 | 国产麻豆交换夫妇 | 一级在线 | 欧洲 | 欧美成人艳星在线播放 | 日韩亚洲一区二区三区 | 日本精品1在线区 | 女人抠逼视频 | 午夜剧场福利社 | 欧美亚洲国产精品久久高清 | 亚洲综合精品一二三区在线 | 91在线一区二区三区 | videosfree性欧美另类 | 兔子先生节目在线观看免费 |