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の実装クラスで共通となる処理を提供する。

Author:

T.Kawasaki

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_TIMEOUT_SECOND	デフォルトのタイムアウト（秒）
protected ExecutorService	executorService	ExecutorService
protected long	timeoutSecond	タイムアウト（秒）

Constructor Summary

Constructors

Constructor	Description
AbstractExecutorServiceFactory()

Method Summary

Modifier and Type	Method	Description
protected boolean	awaitTermination()	スレッド終了を待つ。
protected abstract ExecutorService	createExecutorService()	ExecutorServiceインスタンスを生成する。 サブクラスにて、インスタンスを生成、必要な設定を行うこと。
ExecutorService	getExecutorService()	ExecutorServiceを取得する。
void	initialize()	初期化処理を行う。
protected boolean	needsShutdown()	シャットダウン処理を行う必要があるかどうか判定する。
void	setTimeoutSecond(long timeoutSecond)	スレッドの停止を待機する時間（秒）を設定する。
void	shutdownService()	シャットダウンを行う。
void	startShutdownService()	シャットダウンを開始する。 このメソッド起動後は、以降の要求は受け付けられない。

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_TIMEOUT_SECOND

public static final long DEFAULT_TIMEOUT_SECOND

デフォルトのタイムアウト（秒）

See Also:

• Constant Field Values

timeoutSecond

protected long timeoutSecond

タイムアウト（秒）

executorService

protected ExecutorService executorService

ExecutorService

Constructor Details

AbstractExecutorServiceFactory

public AbstractExecutorServiceFactory()

Method Details

initialize

public void initialize()

Description copied from interface: Initializable

初期化処理を行う。

Specified by:

initialize in interface Initializable

createExecutorService

protected abstract ExecutorService createExecutorService()

ExecutorServiceインスタンスを生成する。 サブクラスにて、インスタンスを生成、必要な設定を行うこと。

Returns:

ExecutorServiceインスタンス

getExecutorService

public ExecutorService getExecutorService()

Description copied from interface: ExecutorServiceFactory

ExecutorServiceを取得する。

Specified by:

getExecutorService in interface ExecutorServiceFactory

Returns:

ExecutorService

startShutdownService

public void startShutdownService()

Description copied from interface: ExecutorServiceFactory

シャットダウンを開始する。 このメソッド起動後は、以降の要求は受け付けられない。

Specified by:

startShutdownService in interface ExecutorServiceFactory

shutdownService

public void shutdownService()

Description copied from interface: ExecutorServiceFactory

シャットダウンを行う。

Specified by:

shutdownService in interface ExecutorServiceFactory

awaitTermination

protected boolean awaitTermination()
                            throws InterruptedException

スレッド終了を待つ。

Returns:

ExecutorService.awaitTermination(long, TimeUnit)の戻り値

Throws:

InterruptedException - 割り込みが発生した場合

needsShutdown

protected boolean needsShutdown()

シャットダウン処理を行う必要があるかどうか判定する。

Returns:

必要がある場合、真

setTimeoutSecond

public void setTimeoutSecond(long timeoutSecond)

スレッドの停止を待機する時間（秒）を設定する。

Parameters:

timeoutSecond - スレッドの停止を待機する時間