public interface ProducerConsumerCompatible
Producer-Consumerパターンに基づいたデータ処理モジュールのインターフェースです. このインターフェースでは, 1つ以上のキューから要素を1つずつ取り出して, 何らかの処理を行った後, 処理結果を別のキューに書き込みます. 各モジュールには, 基本的には入力チャンネルと出力チャンネルが各々1つ以上あり, 各チャンネルにキューが接続される形になります.
修飾子とタイプ | メソッドと説明 |
---|---|
void |
execute(java.lang.Object[] src,
TimeSeriesCompatible[] dest)
ここに処理内容を記述します.
|
java.lang.Class[] |
getInputClasses()
各入力チャンネルが受け付けるオブジェクトのクラスを配列で返します.
|
java.lang.Class[] |
getOutputClasses()
各出力チャンネルが出力するオブジェクトのクラスを配列で返します.
|
void |
stop()
モジュールの処理が終了したときにSPExecutorから呼び出されます
|
void |
terminated(TimeSeriesCompatible[] dest) |
void execute(java.lang.Object[] src, TimeSeriesCompatible[] dest) throws java.lang.InterruptedException
src
- 全入力チャンネルに対するQueueReaderオブジェクトdest
- 全出力チャンネルjava.lang.InterruptedException
java.lang.Class[] getInputClasses()
java.lang.Class[] getOutputClasses()
void stop()
void terminated(TimeSeriesCompatible[] dest) throws java.lang.InterruptedException
java.lang.InterruptedException