|
|||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | ||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | ||||||||
public interface ProducerConsumerCompatible<D,E>
Producer-Consumerパターンに基づいたデータ処理モジュールのインターフェースです. このインターフェースでは, 1つ以上のキューから要素を1つずつ取り出して, 何らかの処理を行った後, 処理結果を別のキューに書き込みます. 各モジュールには, 基本的には入力チャンネルと出力チャンネルが各々1つ以上あり, 各チャンネルにキューが接続される形になります.
| メソッドの概要 | |
|---|---|
TimeSeriesCompatible<E> |
createOutputInstance(int nFrames,
int timeunit)
|
void |
execute(java.util.List<QueueReader<D>> src,
java.util.List<TimeSeriesCompatible<E>> dest)
ここに処理内容を記述します. |
int |
getInputChannels()
入力チャンネル数を返します. |
int |
getOutputChannels()
出力チャンネル数を返します |
void |
setParams(java.util.Map<java.lang.String,java.lang.Object> params)
|
| メソッドの詳細 |
|---|
void setParams(java.util.Map<java.lang.String,java.lang.Object> params)
void execute(java.util.List<QueueReader<D>> src,
java.util.List<TimeSeriesCompatible<E>> dest)
throws java.lang.InterruptedException
src - 全入力チャンネルに対するQueueReaderオブジェクトdest - 全出力チャンネル
java.lang.InterruptedExceptionint getInputChannels()
int getOutputChannels()
TimeSeriesCompatible<E> createOutputInstance(int nFrames,
int timeunit)
|
|||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | ||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | ||||||||