jp.terasoluna.fw.batch.executor
クラス AsyncBatchExecutor

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.executor.AbstractBatchExecutor
      上位を拡張 jp.terasoluna.fw.batch.executor.AbstractJobBatchExecutor
          上位を拡張 jp.terasoluna.fw.batch.executor.AsyncBatchExecutor
すべての実装されたインタフェース:
BatchExecutor

public class AsyncBatchExecutor
extends AbstractJobBatchExecutor

非同期バッチエグゼキュータ。

常駐プロセスとして起動し、ジョブ管理テーブルに登録されたジョブを取得し、ジョブの実行をBatchServantクラスに移譲する。
またジョブ管理テーブルにジョブ実行結果を更新する。

関連項目:
AbstractJobBatchExecutor

フィールドの概要
static String THREAD_GROUP_PREFIX
          スレッドグループプリフィックス.
static String THREAD_GROUP_SEPARATOR
          スレッドグループセパレータ.
static String THREAD_NAME_PREFIX
          スレッド名プリフィックス.
static String THREAD_NAME_SEPARATOR
          スレッド名セパレータ.
 
クラス jp.terasoluna.fw.batch.executor.AbstractJobBatchExecutor から継承されたフィールド
changeStartStatus, DEFAULT_EXECUTOR_END_MONITORING_FILE, DEFAULT_EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME, DEFAULT_EXECUTOR_LOOP_INTERVAL_TIME, DEFAULT_EXECUTOR_QUEUE_CHECK_INTERVAL_TIME, DEFAULT_JOB_AFTER_GC, DEFAULT_JOB_INTERVAL_TIME, EXECUTOR_END_MONITORING_FILE, EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME, executorEndMonitoringFile, executorJobTerminateWaitIntervalTime, JOB_INTERVAL_TIME, jobIntervalTime
 
クラス jp.terasoluna.fw.batch.executor.AbstractBatchExecutor から継承されたフィールド
APPLICATION_CONTEXT, ARGUMENT_COUNT, BEAN_DEFINITION_ADMIN_CLASSPATH_KEY, BEAN_DEFINITION_BUSINESS_CLASSPATH_KEY, BEAN_DEFINITION_DATASOURCE, BEAN_DEFINITION_DEFAULT, BEAN_MESSAGE_ACCESSOR_DEFAULT, cl, DEFAULT_BLOGIC_BEAN_NAME_SUFFIX, DEFAULT_BLOGIC_EXCEPTION_HANDLER_BEAN_NAME, DEFAULT_BLOGIC_EXCEPTION_HANDLER_BEAN_NAME_SUFFIX, defaultApplicationContext, ENV_BLOGIC_APP_STATUS, ENV_CUR_APP_STATUS, ENV_JOB_APP_CD, ENV_JOB_ARG_MAX, ENV_JOB_ARG_NM, ENV_JOB_ARG_NM1, ENV_JOB_ARG_NM10, ENV_JOB_ARG_NM11, ENV_JOB_ARG_NM12, ENV_JOB_ARG_NM13, ENV_JOB_ARG_NM14, ENV_JOB_ARG_NM15, ENV_JOB_ARG_NM16, ENV_JOB_ARG_NM17, ENV_JOB_ARG_NM18, ENV_JOB_ARG_NM19, ENV_JOB_ARG_NM2, ENV_JOB_ARG_NM20, ENV_JOB_ARG_NM3, ENV_JOB_ARG_NM4, ENV_JOB_ARG_NM5, ENV_JOB_ARG_NM6, ENV_JOB_ARG_NM7, ENV_JOB_ARG_NM8, ENV_JOB_ARG_NM9, ENV_JOB_BEAN_DEFINITION_PATH, ENV_JOB_SEQ_ID, FIELD_JOB_ARG, PROPERTY_BEAN_FILENAME_SUFFIX, REPLACE_STRING_JOB_APP_CD, REPLACE_STRING_JOB_APP_CD_LOWER, REPLACE_STRING_JOB_APP_CD_UPPER, REPLACE_STRING_JOB_ARG, REPLACE_STRING_JOB_ARG_MAX, REPLACE_STRING_PREFIX, REPLACE_STRING_SUFFIX, sysQueryDAO, SYSTEM_DATASOURCE_QUERY_DAO, SYSTEM_DATASOURCE_TRANSACTION_MANAGER, SYSTEM_DATASOURCE_UPDATE_DAO, sysTransactionManager, sysUpdateDAO
 
コンストラクタの概要
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をクローズする.
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
 
クラス jp.terasoluna.fw.batch.executor.AbstractBatchExecutor から継承されたメソッド
argumentCopy, closeApplicationContext, convertBLogicParam, executeBatch, executeBatchClass, getApplicationContext, getBeanFileName, getBlogicBeanName, getDataSourceBeanFileName, getDefaultApplicationContext, getDefaultBeanFileName, getDefaultExceptionHandlerBeanName, getExceptionHandlerBeanName, getMethod, getSysQueryDAO, getSysTransactionManager, getSysUpdateDAO, getThreadMessage, init, initDefaultErrorMessage, initJobAppContext, replaceString, setMethod
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

THREAD_GROUP_PREFIX

public static final String THREAD_GROUP_PREFIX
スレッドグループプリフィックス.


THREAD_NAME_PREFIX

public static final String THREAD_NAME_PREFIX
スレッド名プリフィックス.


THREAD_GROUP_SEPARATOR

public static final String THREAD_GROUP_SEPARATOR
スレッドグループセパレータ.

関連項目:
定数フィールド値

THREAD_NAME_SEPARATOR

public static final String THREAD_NAME_SEPARATOR
スレッド名セパレータ.

関連項目:
定数フィールド値
コンストラクタの詳細

AsyncBatchExecutor

protected AsyncBatchExecutor()
コンストラクタ

メソッドの詳細

main

public static void main(String[] args)
メインメソッド.

パラメータ:
args -

executorMain

public static int executorMain(String[] args)
エグゼキュータメインメソッド.

パラメータ:
args -

checkTaskQueue

protected static boolean checkTaskQueue(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor)
タスクエグゼキュータに空きがあるかチェック

パラメータ:
taskExecutor - タスクエグゼキュータ
戻り値:
空きの有無

checkEndFile

protected static boolean checkEndFile(String endFilePath)
終了フラグファイルチェック

パラメータ:
endFilePath - 終了フラグファイルパス
戻り値:
終了フラグファイルチェック結果

logOutputTaskExecutor

protected static void logOutputTaskExecutor(org.apache.commons.logging.Log log,
                                            org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExec)
スレッドプールタスクエグゼキュータのステータスをデバッグログに出力

パラメータ:
log - Log
taskExec - ThreadPoolTaskExecutor

closeRootApplicationContext

protected static void closeRootApplicationContext(org.springframework.context.ApplicationContext context)
ApplicationContextをクローズする.

パラメータ:
context -


Copyright © 2011. All Rights Reserved.