非同期エージェント

非同期エージェントは、他のエージェントと非同期的にやり取りしてより大きなコンピューティング タスクを解決するアプリケーション コンポーネントです。単に "エージェント" と呼ばれることもあります。 エージェントは一定のライフ サイクルを持ったタスクと考えることができます。 たとえば、あるエージェントが入力/出力デバイス (キーボード、ディスク上のファイル、ネットワーク接続など) からデータを読み取り、そのデータが利用できる状態になったら別のエージェントがそのデータに対して処理を実行します。 1 つ目のエージェントは、使用できるデータが他にもあれば、2 つ目のエージェントにメッセージを渡すことによってそのことを伝達します。 同時実行ランタイムのタスク スケジューラは、非効率なプリエンプションを用いず、エージェントによって協調的に実行をブロックしたり譲歩したりできる効率的なメカニズムです。

エージェント ライブラリは、非同期エージェントを表すために concurrency::agent クラスを定義します。 agent は 仮想メソッド concurrency::agent::runを宣言する抽象クラスです。 エージェントによって遂行されるタスクは、run メソッドによって実行されます。 run は抽象クラスであるため、agent から派生したすべてのクラスにはこのメソッドを実装する必要があります。

エージェントのライフ サイクル

エージェントには一定のライフ サイクルがあります。 concurrency::agent_status の列挙体はエージェントのさまざまな状態を定義します。 エージェントの状態がどのように推移するかを次の図に示します。 この図の中で、実線はアプリケーションから呼び出すメソッドを、点線はランタイムから呼び出されるメソッドを表します。

エージェントの状態ダイアグラム

agent_status 列挙型に含まれる個々の状態を次の表に示します。

エージェントの状態

説明

agent_created

エージェントの実行はまだスケジュールされていません。

agent_runnable

ランタイムがエージェントの実行をスケジュール中です。

agent_started

エージェントは開始されて実行中です。

agent_done

エージェントは完了しました。

agent_canceled

エージェントは started 状態になる前に取り消されました。

agent_created がエージェントの初期状態です。また、agent_runnableagent_started はアクティブな状態を、agent_doneagent_canceled は終了状態を表します。

agent オブジェクトの現在の状態を取得するために concurrency::agent::status のメソッドを使用します。 status は同時実行セーフなメソッドですが、status メソッドから制御が戻るまでにエージェントの状態が変化する場合があります。 たとえば、status メソッドを呼び出した時点でエージェントの状態が agent_started だったとして、status メソッドから制御が戻った直後には agent_done 状態になっていることも考えられます。

メソッドおよび機能

次の表に、agent クラスの重要なメソッドをいくつか示します。 agent クラスのすべてのメソッドの詳細については、「agent クラス」を参照してください。

方法

説明

start

agent オブジェクトの実行をスケジュールし、agent_runnable 状態に設定します。

run

agent オブジェクトが遂行することになっているタスクを実行します。

done

エージェントを agent_done 状態に移行させます。

cancel

エージェントが開始されていなかった場合、このメソッドは、エージェントの実行を取り消して、agent_canceled 状態に設定します。

status

agent オブジェクトの現在の状態を取得します。

wait

agent オブジェクトが agent_done 状態または agent_canceled 状態になるまで待機します。

wait_for_all

指定されたすべての agent オブジェクトが agent_done 状態または agent_canceled 状態になるまで待機します。

wait_for_one

指定された agent オブジェクトが少なくとも 1 つ agent_done 状態または agent_canceled 状態になるまで待機します。

エージェント オブジェクトを作成したら、それを適用するに concurrency::agent::start のメソッドを呼び出します。 エージェントのスケジュール後、ランタイムが run メソッドを呼び出し、その状態を agent_runnable に設定します。

ランタイムは非同期エージェントによってスローされた例外を管理しません。 例外処理とエージェントの詳細については、「同時実行ランタイムでの例外処理」を参照してください。

基本的なエージェント ベースのアプリケーションを作成する方法の例については、「チュートリアル: エージェント ベースのアプリケーションの作成」を参照してください。

参照

概念

非同期エージェント ライブラリ