|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectjp.terasoluna.fw.batch.executor.AbstractBatchExecutor
jp.terasoluna.fw.batch.executor.AbstractJobBatchExecutor
jp.terasoluna.fw.batch.executor.AsyncBatchExecutor
public class AsyncBatchExecutor
非同期バッチエグゼキュータ。
常駐プロセスとして起動し、ジョブ管理テーブルに登録されたジョブを取得し、ジョブの実行をBatchServantクラスに移譲する。
またジョブ管理テーブルにジョブ実行結果を更新する。
AbstractJobBatchExecutor
フィールドの概要 | |
---|---|
protected static long |
availableThreadThresholdCount
空きスレッド残数閾値 |
protected static long |
availableThreadThresholdWait
空きスレッド残数閾値以下の場合のウェイト時間(ミリ秒) |
protected static long |
DEFAULT_AVAILABLE_THREADTHRESHOLD_COUNT
空きスレッド残数閾値のデフォルト値 |
protected static long |
DEFAULT_AVAILABLE_THREADTHRESHOLD_WAIT
空きスレッド残数閾値以下の場合のウェイト時間(ミリ秒)のデフォルト値 |
protected static long |
DEFAULT_EXECUTE_RETRY_COUNTMAX
ジョブ実行リトライ回数のデフォルト値 |
protected static long |
DEFAULT_EXECUTE_RETRY_INTERVAL
ジョブ実行リトライ間隔(ミリ秒)のデフォルト値 |
protected static long |
executeRetryCountMax
ジョブ実行リトライ回数 |
protected static long |
executeRetryInterval
ジョブ実行リトライ間隔(ミリ秒) |
static String |
THREAD_GROUP_PREFIX
スレッドグループプリフィックス. |
static String |
THREAD_GROUP_SEPARATOR
スレッドグループセパレータ. |
static String |
THREAD_NAME_PREFIX
スレッド名プリフィックス. |
static String |
THREAD_NAME_SEPARATOR
スレッド名セパレータ. |
protected static AtomicInteger |
threadGroupNo
スレッドグループ番号. |
コンストラクタの概要 | |
---|---|
protected |
AsyncBatchExecutor()
コンストラクタ |
メソッドの概要 | |
---|---|
protected static boolean |
checkEndFile(String endFilePath)
終了フラグファイルチェック |
protected static boolean |
checkTaskQueue(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor)
タスクエグゼキュータに空きがあるかチェック |
protected static void |
closeRootApplicationContext(org.springframework.context.ApplicationContext context)
ApplicationContextをクローズする. |
protected static boolean |
executeJob(AsyncBatchExecutor executor,
org.springframework.context.ApplicationContext ctx,
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor,
String batchTaskServantName,
BatchJobListResult batchJobListResult)
バッチ処理実行. |
static int |
executorMain(String[] args)
エグゼキュータメインメソッド. |
protected static void |
logOutputTaskExecutor(org.apache.commons.logging.Log log,
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExec)
スレッドプールタスクエグゼキュータのステータスをデバッグログに出力 |
static void |
main(String[] args)
メインメソッド. |
クラス jp.terasoluna.fw.batch.executor.AbstractJobBatchExecutor から継承されたメソッド |
---|
endBatchStatus, executeBatch, getExecutorEndMonitoringFile, getExecutorJobTerminateWaitIntervalTime, getJobIntervalTime, initDefaultAppContext, initParameter, initSystemDatasourceDao, judgmentStatus, setChangeStartStatus, startBatchStatus, updateBatchStatus |
クラス java.lang.Object から継承されたメソッド |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
フィールドの詳細 |
---|
protected static final long DEFAULT_EXECUTE_RETRY_INTERVAL
protected static final long DEFAULT_EXECUTE_RETRY_COUNTMAX
protected static final long DEFAULT_AVAILABLE_THREADTHRESHOLD_COUNT
protected static final long DEFAULT_AVAILABLE_THREADTHRESHOLD_WAIT
public static final String THREAD_GROUP_PREFIX
public static final String THREAD_NAME_PREFIX
public static final String THREAD_GROUP_SEPARATOR
public static final String THREAD_NAME_SEPARATOR
protected static AtomicInteger threadGroupNo
protected static long executeRetryInterval
protected static long executeRetryCountMax
protected static long availableThreadThresholdCount
protected static long availableThreadThresholdWait
コンストラクタの詳細 |
---|
protected AsyncBatchExecutor()
メソッドの詳細 |
---|
public static void main(String[] args)
args
- public static int executorMain(String[] args)
args
- protected static boolean executeJob(AsyncBatchExecutor executor, org.springframework.context.ApplicationContext ctx, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor, String batchTaskServantName, BatchJobListResult batchJobListResult)
executor
- AsyncBatchExecutorctx
- ApplicationContexttaskExecutor
- ThreadPoolTaskExecutorbatchTaskServantName
- StringbatchJobListResult
- BatchJobListResult
protected static boolean checkTaskQueue(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor)
taskExecutor
- タスクエグゼキュータ
protected static boolean checkEndFile(String endFilePath)
endFilePath
- 終了フラグファイルパス
protected static void logOutputTaskExecutor(org.apache.commons.logging.Log log, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExec)
log
- LogtaskExec
- ThreadPoolTaskExecutorprotected static void closeRootApplicationContext(org.springframework.context.ApplicationContext context)
context
-
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |