parallel.pool.PollableDataQueue
クライアントとワーカーの間でのデータの送信とポーリング
説明
PollableDataQueue
により、計算の実行中に並列プール内のワーカーとクライアント間でデータまたはメッセージを非同期で送信およびポーリングできます。計算の中間値と進行状況を取得できます。
並列プールのワーカーからクライアントにデータを送り返すには、まずクライアント内に PollableDataQueue
を作成します。この PollableDataQueue
を、parfor
ループ、または parfeval
などの他の並列言語構成に渡します。ワーカーから send
を呼び出して、データをクライアントに送り返します。クライアントで poll
を使用して、ワーカーから送信されたメッセージまたはデータの結果を取得します。
必要に応じて、
PollableDataQueue
を作成するワーカーまたはクライアントからsend
を呼び出すことができます。ワーカー上にキューを作成し、そのキューをクライアントに送り返すことにより、逆方向の通信を有効にできます。ただし、ワーカーから別のワーカーにキューを送信することはできません。代わりに
spmd
、labSend
またはlabReceive
を使用してください。その他すべてのハンドル オブジェクトとは異なり、
PollableDataQueue
インスタンスとDataQueue
インスタンスはワーカーに送信されても接続されたままとなります。
作成
説明
は、さまざまなワーカーからのメッセージ (またはデータ) の送信およびポーリングに使用できるオブジェクトを作成します。データを受信するワーカーまたはクライアント上で、p
= parallel.pool.PollableDataQueuePollableDataQueue
を作成します。
プロパティ
例
バージョン履歴
参考
gcp
| poll
| parfor
| send
| parallel.pool.DataQueue
| labReceive
| labSend
| parfeval
| parfevalOnAll