|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectjp.terasoluna.fw.collector.AbstractCollector<P>
public abstract class AbstractCollector<P>
AbstractCollector抽象クラス
フィールドの概要 | |
---|---|
protected boolean |
beginning
実行開始フラグ |
protected static int |
CURRENT_QUEUE_CHECK_SIZE
現在キュー保持数チェックサイズ |
protected Queue<DataValueObject> |
currentQueue
現在キュー |
static int |
DEFAULT_QUEUE_SIZE
デフォルトのキューサイズ |
protected static int |
DEFAULT_SLEEP_WAIT
デフォルトスリープ時間(msec) |
protected CollectorExceptionHandler |
exceptionHandler
CollectorExceptionHandler |
protected boolean |
finish
終了フラグ |
protected Future<?> |
fo
非同期処理の結果を取得するためのクラス |
protected static int |
PREVIOUS_QUEUE_CHECK_SIZE
後方キュー保持数チェックサイズ |
protected Queue<DataValueObject> |
previousQueue
後方キュー |
protected Queue<DataValueObject> |
queue
キュー |
protected int |
queueSize
キューサイズ |
protected int |
sleepWait
スリープ時間(msec) |
protected ValidationErrorHandler |
validationErrorHandler
ValidationErrorHandler |
protected org.springframework.validation.Validator |
validator
Validator |
protected static AtomicBoolean |
verboseLog
冗長ログ出力フラグ. |
コンストラクタの概要 | |
---|---|
AbstractCollector()
|
メソッドの概要 | |
---|---|
protected void |
addQueue(DataValueObject dataValueObject)
キューにデータを追加する。 |
void |
close()
このストリームを閉じて、それに関連するすべてのシステムリソースを解放します。 |
static void |
closeQuietly(Collector<?> collector)
Collectorをクローズする。 |
protected Queue<DataValueObject> |
createCurrentQueue()
currentキューを作成する |
protected Queue<DataValueObject> |
createPreviousQueue()
previousキューを作成する |
protected Queue<DataValueObject> |
createQueue()
キューを作成する |
protected void |
execute()
AbstractCollectorを実行する。 |
protected void |
finalize()
|
P |
getCurrent()
現在の要素を返します。 |
protected ExecutorService |
getExecutor()
getExecutorメソッド. |
P |
getNext()
ポインタを次の要素に移さずに次の要素を返します。 |
P |
getPrevious()
1件前の要素を返します。 |
protected Queue<DataValueObject> |
getQueue()
キューを取得する。 |
protected int |
getSleepWait()
スリープ時間(msec) |
protected CollectorExceptionHandlerStatus |
handleException(DataValueObject dataValueObject)
例外発生時の処理 |
protected ValidateErrorStatus |
handleValidationError(DataValueObject dataValueObject,
org.springframework.validation.Errors errors)
入力チェックエラー時の処理. |
boolean |
hasNext()
繰り返し処理でさらに要素がある場合に true を返します。 |
protected boolean |
isFinish()
終了フラグの状態を確認する。 |
Iterator<P> |
iterator()
|
P |
next()
繰り返し処理で次の要素を返します。 |
void |
remove()
基になるコレクションから、反復子によって最後に返された要素を削除します (任意のオペレーション)。 |
protected void |
setFinish()
終了フラグを設定する。 |
protected void |
setFinish(boolean finish)
終了フラグを設定する。 |
protected void |
setQueueSize(int queueSize)
キューサイズを指定する。 |
protected void |
setSleepWait(int sleepWait)
スリープ時間(msec) |
static void |
setVerbose(boolean verbose)
冗長ログ出力フラグを設定する。 |
protected ValidateErrorStatus |
validate(DataValueObject dataValueObject)
入力チェックを行う. |
クラス java.lang.Object から継承されたメソッド |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
インタフェース java.util.concurrent.Callable から継承されたメソッド |
---|
call |
フィールドの詳細 |
---|
public static final int DEFAULT_QUEUE_SIZE
protected static final int DEFAULT_SLEEP_WAIT
protected static final int CURRENT_QUEUE_CHECK_SIZE
protected static final int PREVIOUS_QUEUE_CHECK_SIZE
protected static AtomicBoolean verboseLog
protected int queueSize
protected int sleepWait
protected Queue<DataValueObject> queue
protected Queue<DataValueObject> currentQueue
protected Queue<DataValueObject> previousQueue
protected volatile Future<?> fo
protected volatile boolean finish
protected volatile boolean beginning
protected org.springframework.validation.Validator validator
protected ValidationErrorHandler validationErrorHandler
protected CollectorExceptionHandler exceptionHandler
コンストラクタの詳細 |
---|
public AbstractCollector()
メソッドの詳細 |
---|
protected void execute()
public boolean hasNext()
※本メソッドはマルチスレッドセーフでありません。
Iterator<P>
内の hasNext
Iterator.hasNext()
public P next()
※本メソッドはマルチスレッドセーフでありません。
Iterator<P>
内の next
NoSuchElementException
- 繰り返し処理でそれ以上要素がない場合Iterator.next()
public P getNext()
nullの場合は次の要素が存在しないことを示します。
ポインタは移動しません。
※本メソッドはマルチスレッドセーフでありません。
Collector<P>
内の getNext
Collector.getNext()
public P getPrevious()
1件目の場合はnullが返ります。
ポインタは移動しません。
※本メソッドはマルチスレッドセーフでありません。
Collector<P>
内の getPrevious
Collector.getPrevious()
public P getCurrent()
nullの場合は現在の要素が存在しないことを示します。
ポインタは移動しません。
※本メソッドはマルチスレッドセーフでありません。
Collector<P>
内の getCurrent
Collector.getCurrent()
public void close()
※本メソッドはマルチスレッドセーフでありません。
Closeable
内の close
IOException
- 入出力エラーが発生した場合Closeable.close()
public void remove()
※本メソッドはマルチスレッドセーフでありません。
Iterator<P>
内の remove
UnsupportedOperationException
- Iterator が remove オペレーションをサポートしない場合
IllegalStateException
- next メソッドがまだ呼び出されてない場合、または next メソッドの最後の呼び出しのあとに remove メソッドがすでに呼び出されている場合Iterator.remove()
protected void finalize() throws Throwable
Object
内の finalize
Throwable
public Iterator<P> iterator()
Iterable<P>
内の iterator
protected ExecutorService getExecutor()
protected Queue<DataValueObject> createQueue()
protected Queue<DataValueObject> createCurrentQueue()
protected Queue<DataValueObject> createPreviousQueue()
protected Queue<DataValueObject> getQueue()
protected void setQueueSize(int queueSize)
queueSize
- intprotected int getSleepWait()
protected void setSleepWait(int sleepWait)
sleepWait
- スリープ時間(msec)protected void addQueue(DataValueObject dataValueObject) throws InterruptedException
dataValueObject
- DataValueObject
InterruptedException
protected ValidateErrorStatus validate(DataValueObject dataValueObject)
dataValueObject
- DataValueObject
protected ValidateErrorStatus handleValidationError(DataValueObject dataValueObject, org.springframework.validation.Errors errors)
dataValueObject
- DataValueObjecterrors
- Errors
protected CollectorExceptionHandlerStatus handleException(DataValueObject dataValueObject)
dataValueObject
- DataValueObject
protected boolean isFinish()
protected void setFinish()
protected void setFinish(boolean finish)
finish
- public static void closeQuietly(Collector<?> collector)
引数に渡されたcollectorがnullでなければクローズする。
また、クローズする際にIO例外が発生した場合は無視する。
collector
- Collectorpublic static void setVerbose(boolean verbose)
verbose
- 冗長ログ出力フラグ
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |