Public メソッド | |
| def | __init__ |
| コンストラクタ | |
| def | __del__ |
| デストラクタ | |
| def | update |
| Observer関数 | |
| def | run |
| タスク開始関数 | |
| def | release |
| タスク終了関数 | |
データ構造 | |
| class | NewData |
| データ状態管理用内部クラス [詳細] | |
バッファ内に新規データが格納されたタイミングで、その新規データを送信する。 データ送出タイミングを待つコンシューマを、送出する側とは異なるスレッドで 動作させる場合に使用。 Publisherの駆動は、データ送出のタイミングになるまでブロックされ、 送出タイミングの通知を受けると、即座にコンシューマの送出処理を呼び出す。
PublisherNew.py の 38 行で定義されています。
| def __init__ | ( | self, | ||
| consumer, | ||||
| property | ||||
| ) |
コンストラクタ
コンストラクタ 本 Publisher 用新規スレッドを生成する。
| self | ||
| consumer | データ送出を待つコンシューマ | |
| property | 本Publisherの駆動制御情報を設定したPropertyオブジェクト (本Publisherでは未使用) |
PublisherNew.py の 58 行で定義されています。
| def __del__ | ( | self | ) |
| def update | ( | self | ) |
Observer関数
送出タイミング時に呼び出す。 ブロックしている当該Publisherの駆動が開始され、コンシューマへの送出処理が 行われる。
| self |
PublisherNew.py の 95 行で定義されています。
| def run | ( | self | ) |
| def release | ( | self | ) |
タスク終了関数
ACE_Task::release() のオーバーライド 駆動フラグをfalseに設定し、本 Publisher の駆動を停止する。 ただし、駆動スレッドがブロックされている場合には、 最大1回コンシューマの送出処理が呼び出される場合がある。
| self |
PublisherNew.py の 147 行で定義されています。
1.5.4