|
||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||
java.lang.Objectjp.terasoluna.fw.collector.AbstractCollector<P>
public abstract class AbstractCollector<P>
AbstractCollector抽象クラス
| フィールドの概要 | |
|---|---|
protected AtomicLong |
acquireDataCount
データカウント |
protected boolean |
beginning
実行開始フラグ |
protected AbstractCollector<?> |
child
子スレッド側インスタンス |
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)
キューにデータを追加する。 |
protected void |
addQueue(DataValueObject dataValueObject,
boolean force)
キューにデータを追加する。 |
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
protected AbstractCollector<?> child
protected AtomicLong acquireDataCount
| コンストラクタの詳細 |
|---|
public AbstractCollector()
| メソッドの詳細 |
|---|
protected void execute()
public boolean hasNext()
※本メソッドはマルチスレッドセーフでありません。
Iterator<P> 内の hasNextIterator.hasNext()public P next()
※本メソッドはマルチスレッドセーフでありません。
Iterator<P> 内の nextNoSuchElementException - 繰り返し処理でそれ以上要素がない場合Iterator.next()public P getNext()
nullの場合は次の要素が存在しないことを示します。
ポインタは移動しません。
※本メソッドはマルチスレッドセーフでありません。
Collector<P> 内の getNextCollector.getNext()public P getPrevious()
1件目の場合はnullが返ります。
ポインタは移動しません。
※本メソッドはマルチスレッドセーフでありません。
Collector<P> 内の getPreviousCollector.getPrevious()public P getCurrent()
nullの場合は現在の要素が存在しないことを示します。
ポインタは移動しません。
※本メソッドはマルチスレッドセーフでありません。
Collector<P> 内の getCurrentCollector.getCurrent()public void close()
※本メソッドはマルチスレッドセーフでありません。
Closeable 内の closeIOException - 入出力エラーが発生した場合Closeable.close()public void remove()
※本メソッドはマルチスレッドセーフでありません。
Iterator<P> 内の removeUnsupportedOperationException - Iterator が remove オペレーションをサポートしない場合
IllegalStateException - next メソッドがまだ呼び出されてない場合、または next メソッドの最後の呼び出しのあとに remove メソッドがすでに呼び出されている場合Iterator.remove()
protected void finalize()
throws Throwable
Object 内の finalizeThrowablepublic Iterator<P> iterator()
Iterable<P> 内の iteratorprotected 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 void addQueue(DataValueObject dataValueObject,
boolean force)
throws InterruptedException
dataValueObject - DataValueObjectforce - boolean 強制キューイングフラグ
InterruptedExceptionprotected 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 - 冗長ログ出力フラグ
|
||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||