jp.terasoluna.fw.batch.springsupport.standard
クラス FixedThreadPoolWorkerExecutorService

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.springsupport.standard.FixedThreadPoolWorkerExecutorService
すべての実装されたインタフェース:
WorkerExecutorService

public class FixedThreadPoolWorkerExecutorService
extends java.lang.Object
implements WorkerExecutorService

WorkerExecutorService インタフェースの標準実装クラス。

Executors.newFixedThreadPool() で作成したスレッドプールで、 ワーカを実行する。


フィールドの概要
private  JobExceptionHandler defaultJobExceptionHandler
          デフォルト例外ハンドラ。
private  java.util.LinkedHashMap<JobException,JobExceptionHandler> exceptionHandlerMap
          例外ハンドラを格納したMap。
private  java.util.concurrent.ExecutorService executorService
          実行サービス。
private  ThrowableHandler throwableHandler
          Throwableハンドラ。
 
コンストラクタの概要
FixedThreadPoolWorkerExecutorService(int threads)
          コンストラクタ。
 
メソッドの概要
 void destroy()
          インスタンスを破棄する際に、Spring Frameworkから呼ばれるコール バックメソッド。
 void setDefaultJobExceptionHandler(JobExceptionHandler defaultJobExceptionHandler)
          デフォルト例外ハンドラを設定する。
 void setExceptionHandlerMap(java.util.LinkedHashMap<JobException,JobExceptionHandler> exceptionHandlerMap)
          例外ハンドラを格納したMapを設定する。
 void setThrowableHandler(ThrowableHandler throwableHandler)
          Throwableハンドラを設定する。
 java.util.concurrent.Future<?> submit(QueueProcessor queueProcessor, WorkQueue workQueue, JobStatus jobStatus)
          ワーカー実行を登録する。
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

executorService

private java.util.concurrent.ExecutorService executorService
実行サービス。


exceptionHandlerMap

private java.util.LinkedHashMap<JobException,JobExceptionHandler> exceptionHandlerMap
例外ハンドラを格納したMap。


defaultJobExceptionHandler

private JobExceptionHandler defaultJobExceptionHandler
デフォルト例外ハンドラ。


throwableHandler

private ThrowableHandler throwableHandler
Throwableハンドラ。

コンストラクタの詳細

FixedThreadPoolWorkerExecutorService

public FixedThreadPoolWorkerExecutorService(int threads)
コンストラクタ。

パラメータ:
threads - スレッド数
メソッドの詳細

submit

public java.util.concurrent.Future<?> submit(QueueProcessor queueProcessor,
                                             WorkQueue workQueue,
                                             JobStatus jobStatus)
ワーカー実行を登録する。

定義:
インタフェース WorkerExecutorService 内の submit
パラメータ:
queueProcessor - キュー処理プロセッサ
workQueue - キュー
jobStatus - ジョブステータス
戻り値:
ワーカの処理結果に非同期でアクセスするためのフューチャー

destroy

public void destroy()
インスタンスを破棄する際に、Spring Frameworkから呼ばれるコール バックメソッド。

実行サービスをシャットダウンする。


setExceptionHandlerMap

public void setExceptionHandlerMap(java.util.LinkedHashMap<JobException,JobExceptionHandler> exceptionHandlerMap)
例外ハンドラを格納したMapを設定する。

パラメータ:
exceptionHandlerMap - 例外ハンドラを格納したMap

setDefaultJobExceptionHandler

public void setDefaultJobExceptionHandler(JobExceptionHandler defaultJobExceptionHandler)
デフォルト例外ハンドラを設定する。

パラメータ:
defaultJobExceptionHandler - デフォルト例外ハンドラ

setThrowableHandler

public void setThrowableHandler(ThrowableHandler throwableHandler)
Throwableハンドラを設定する。

パラメータ:
throwableHandler - Throwableハンドラ