pythonはイベントオブジェクトasyncico.Eventを使って協働プロセスの操作を同期させます。
イベントオブジェクトasyncico.Eventは、threadingn.Eventに基づいて実現される。
イベントは、複数の協働同期動作をトリガする信号であり、
例は以下の通りです
この例ではasyncico.Protocolを使ってechoクライアントを作成して、asyncicoとlogingを入庫します。
次に、送信されたメッセージMESSAGESを定義する。
接続サーバのアドレスSERVER_を作成します。ADDRESSは、引き続きEchoCientクラスを作成し、asyncico.Protocolを継承します。
このクラスのコンストラクション関数では、二つのパラメータmessagesとfutureを受信します。
メッセージは送信するメッセージデータを指定しています。Futureは、socketがデータを受信したことを通知するために使用されます。または、サーバがsocketをオフにするイベント通知です。イベントループは、このプロトコルが完了したことを知るために、プログラム全体を終了することができます。
connectionmade関数は、socketがサーバに接続されているときに呼び出すと、すぐにサーバにデータを送信し、データの送信が完了したらeofフラグを送信します。
サーバが受信したデータとマークはクライアントに返信します。クライアントのdata_received関数受信データ、eof_received関数は終了フラグを受信します。
connectionlost関数はサーバから受信して接続を切断します。
この行のコード:
clientcompletteed=asyncico.Future()
協働完了トリガイベントを作成します。
イベントでloop.create_connection関数は一つのパラメータしか受信できません。functools.partialを使用して複数のパラメータを一つのパラメータに包装する必要があります。
後はイベントサイクルで協働します。
イベントは、複数の協働同期動作をトリガする信号であり、
例は以下の通りです
import asyncio
import 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: False
coro2 waiting for event
coro1 waiting for event
setting event in callback
coro2 triggered
coro1 triggered
event end state: True
追加知識:pythonで協働プログラムを使ってechoクライアントを作成します。この例ではasyncico.Protocolを使ってechoクライアントを作成して、asyncicoとlogingを入庫します。
次に、送信されたメッセージMESSAGESを定義する。
接続サーバのアドレスSERVER_を作成します。ADDRESSは、引き続きEchoCientクラスを作成し、asyncico.Protocolを継承します。
このクラスのコンストラクション関数では、二つのパラメータmessagesとfutureを受信します。
メッセージは送信するメッセージデータを指定しています。Futureは、socketがデータを受信したことを通知するために使用されます。または、サーバがsocketをオフにするイベント通知です。イベントループは、このプロトコルが完了したことを知るために、プログラム全体を終了することができます。
connectionmade関数は、socketがサーバに接続されているときに呼び出すと、すぐにサーバにデータを送信し、データの送信が完了したらeofフラグを送信します。
サーバが受信したデータとマークはクライアントに返信します。クライアントのdata_received関数受信データ、eof_received関数は終了フラグを受信します。
connectionlost関数はサーバから受信して接続を切断します。
この行のコード:
clientcompletteed=asyncico.Future()
協働完了トリガイベントを作成します。
イベントでloop.create_connection関数は一つのパラメータしか受信できません。functools.partialを使用して複数のパラメータを一つのパラメータに包装する必要があります。
後はイベントサイクルで協働します。
import asyncio
import functools
import logging
import 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はイベントの対象であるasyncico.Eventを使って協働しています。これは小編集が皆さんに共有している内容です。参考にしていただければと思います。どうぞよろしくお願いします。