クラス AsyncItemProcessor<I,O>
java.lang.ObjectSE
org.springframework.batch.integration.async.AsyncItemProcessor<I,O>
- 型パラメーター:
I
- 入力オブジェクト型O
- 出力オブジェクト型 (未来に包まれます)
- 実装されたすべてのインターフェース:
ItemProcessor<I,
,FutureSE<O>> org.springframework.beans.factory.InitializingBean
public class AsyncItemProcessor<I,O>
extends ObjectSE
implements ItemProcessor<I,FutureSE<O>>, org.springframework.beans.factory.InitializingBean
ネストされたプロセッサーおよびバックグラウンドに委譲する
ItemProcessor
。バックグラウンド処理を可能にするために、プロセッサーからの戻り値は Future
SE であり、クライアントが項目を使用できるようにする前に、これを解凍する必要があります。Future
SE は通常 ItemWriter
でアンラップされるため、ライフサイクルと統計の制限があります (フレームワークはプロセッサーの結果がわからないため)。完全なリストではありませんが、StepExecution.getFilterCount()
などはフィルターされた項目の数を反映せず、ItemProcessListener.onProcessError(Object, Exception)
は呼び出されません。
- 作成者:
- Dave Syer, Mahmoud Ben Hassine
- 関連事項:
コンストラクターのサマリー
メソッドのサマリー
修飾子と型メソッド説明void
必須プロパティ(setDelegate(ItemProcessor)
)を確認してください。提供されたアイテムプロセッサーに委譲することにより、入力を変換します。void
setDelegate
(ItemProcessor<I, O> delegate) バックグラウンドスレッドで処理を委譲するために使用するItemProcessor
。void
setTaskExecutor
(org.springframework.core.task.TaskExecutor taskExecutor) アイテム処理をバックグラウンドで続行できるようにするために使用するTaskExecutor
。
コンストラクターの詳細
AsyncItemProcessor
public AsyncItemProcessor()
メソッドの詳細
afterPropertiesSet
必須プロパティ(setDelegate(ItemProcessor)
)を確認してください。- 次で指定:
- インターフェース
org.springframework.beans.factory.InitializingBean
のafterPropertiesSet
- 例外:
ExceptionSE
- 関連事項:
InitializingBean.afterPropertiesSet()
setDelegate
バックグラウンドスレッドで処理を委譲するために使用するItemProcessor
。- パラメーター:
delegate
- デリゲートとして使用するItemProcessor
setTaskExecutor
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor) アイテム処理をバックグラウンドで続行できるようにするために使用するTaskExecutor
。デフォルトはSyncTaskExecutor
であるため、これがオーバーライドされない限り、スレッドは作成されません。- パラメーター:
taskExecutor
-TaskExecutor
process
提供されたアイテムプロセッサーに委譲することにより、入力を変換します。戻り値はFuture
SE にラップされるため、クライアントは後でアンパックできます。- 次で指定:
- インターフェース
ItemProcessor<I,
のO> process
- パラメーター:
item
- 処理されるため、null
は使用しないでください。- 戻り値:
- 処理を続行するために潜在的に変更された項目または新しい項目、提供された項目の処理を続行しない場合は
null
- 例外:
ExceptionSE
- 処理中に例外が発生した場合にスローされます。- 関連事項: