Package nablarch.fw.invoker
Class AbstractExecutorServiceFactory
java.lang.Object
nablarch.fw.invoker.AbstractExecutorServiceFactory
- All Implemented Interfaces:
Initializable
,ExecutorServiceFactory
- Direct Known Subclasses:
FixedExecutorServiceFactory
@Published(tag="architect")
public abstract class AbstractExecutorServiceFactory
extends Object
implements ExecutorServiceFactory, Initializable
ExecutorServiceFactory
の実装をサポートする抽象クラス。
ExecutorServiceFactory
の実装クラスで共通となる処理を提供する。-
Field Summary
Modifier and TypeFieldDescriptionstatic final long
デフォルトのタイムアウト(秒)protected ExecutorService
protected long
タイムアウト(秒) -
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
スレッド終了を待つ。protected abstract ExecutorService
ExecutorService
インスタンスを生成する。 サブクラスにて、インスタンスを生成、必要な設定を行うこと。ExecutorService
を取得する。void
初期化処理を行う。protected boolean
シャットダウン処理を行う必要があるかどうか判定する。void
setTimeoutSecond
(long timeoutSecond) スレッドの停止を待機する時間(秒)を設定する。void
シャットダウンを行う。void
シャットダウンを開始する。 このメソッド起動後は、以降の要求は受け付けられない。
-
Field Details
-
DEFAULT_TIMEOUT_SECOND
public static final long DEFAULT_TIMEOUT_SECONDデフォルトのタイムアウト(秒)- See Also:
-
timeoutSecond
protected long timeoutSecondタイムアウト(秒) -
executorService
-
-
Constructor Details
-
AbstractExecutorServiceFactory
public AbstractExecutorServiceFactory()
-
-
Method Details
-
initialize
public void initialize()Description copied from interface:Initializable
初期化処理を行う。- Specified by:
initialize
in interfaceInitializable
-
createExecutorService
ExecutorService
インスタンスを生成する。 サブクラスにて、インスタンスを生成、必要な設定を行うこと。- Returns:
ExecutorService
インスタンス
-
getExecutorService
Description copied from interface:ExecutorServiceFactory
ExecutorService
を取得する。- Specified by:
getExecutorService
in interfaceExecutorServiceFactory
- Returns:
ExecutorService
-
startShutdownService
public void startShutdownService()Description copied from interface:ExecutorServiceFactory
シャットダウンを開始する。 このメソッド起動後は、以降の要求は受け付けられない。- Specified by:
startShutdownService
in interfaceExecutorServiceFactory
-
shutdownService
public void shutdownService()Description copied from interface:ExecutorServiceFactory
シャットダウンを行う。- Specified by:
shutdownService
in interfaceExecutorServiceFactory
-
awaitTermination
スレッド終了を待つ。- Returns:
ExecutorService.awaitTermination(long, TimeUnit)
の戻り値- Throws:
InterruptedException
- 割り込みが発生した場合
-
needsShutdown
protected boolean needsShutdown()シャットダウン処理を行う必要があるかどうか判定する。- Returns:
- 必要がある場合、真
-
setTimeoutSecond
public void setTimeoutSecond(long timeoutSecond) スレッドの停止を待機する時間(秒)を設定する。- Parameters:
timeoutSecond
- スレッドの停止を待機する時間
-