パッケージ org.springframework.batch.integration.async

クラス 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。バックグラウンド処理を可能にするために、プロセッサーからの戻り値は FutureSE であり、クライアントが項目を使用できるようにする前に、これを解凍する必要があります。

FutureSE は通常 ItemWriter でアンラップされるため、ライフサイクルと統計の制限があります (フレームワークはプロセッサーの結果がわからないため)。完全なリストではありませんが、StepExecution.getFilterCount() などはフィルターされた項目の数を反映せず、ItemProcessListener.onProcessError(Object, Exception) は呼び出されません。

作成者:
Dave Syer, Mahmoud Ben Hassine
関連事項:

  • コンストラクターの詳細

    • AsyncItemProcessor

      public AsyncItemProcessor()

  • メソッドの詳細

    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      必須プロパティ（setDelegate(ItemProcessor)）を確認してください。
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 
      例外:
      ExceptionSE
      関連事項:
      • InitializingBean.afterPropertiesSet()

    • setDelegate

      public void setDelegate(ItemProcessor<I,O> delegate)
      バックグラウンドスレッドで処理を委譲するために使用する ItemProcessor。
      パラメーター:
      delegate - デリゲートとして使用する ItemProcessor

    • setTaskExecutor

      public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
      アイテム処理をバックグラウンドで続行できるようにするために使用する TaskExecutor。デフォルトは SyncTaskExecutor であるため、これがオーバーライドされない限り、スレッドは作成されません。
      パラメーター:
      taskExecutor - TaskExecutor

    • process

      @Nullable public FutureSE<O> process(I item) throws ExceptionSE
      提供されたアイテムプロセッサーに委譲することにより、入力を変換します。戻り値は FutureSE にラップされるため、クライアントは後でアンパックできます。
      次で指定:
      インターフェース ItemProcessor<I,O> の process 
      パラメーター:
      item - 処理されるため、null は使用しないでください。
      戻り値:
      処理を続行するために潜在的に変更された項目または新しい項目、提供された項目の処理を続行しない場合は null 
      例外:
      ExceptionSE - 処理中に例外が発生した場合にスローされます。
      関連事項: