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 java.lang.Object
implements ExecutorServiceFactory, Initializable

ExecutorServiceFactoryの実装をサポートする抽象クラス。 ExecutorServiceFactoryの実装クラスで共通となる処理を提供する。

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AbstractExecutorServiceFactory()

Method Summary

Modifier and Type	Method and Description
protected boolean	awaitTermination() スレッド終了を待つ。
protected abstract java.util.concurrent.ExecutorService	createExecutorService() ExecutorServiceインスタンスを生成する。 サブクラスにて、インスタンスを生成、必要な設定を行うこと。
java.util.concurrent.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 Detail

DEFAULT_TIMEOUT_SECOND

public static final long DEFAULT_TIMEOUT_SECOND

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

See Also:

Constant Field Values

timeoutSecond

protected long timeoutSecond

タイムアウト（秒）

executorService

protected java.util.concurrent.ExecutorService executorService

ExecutorService

Constructor Detail

AbstractExecutorServiceFactory

public AbstractExecutorServiceFactory()

Method Detail

initialize

public void initialize()

Description copied from interface: Initializable

初期化処理を行う。

Specified by:

initialize in interface Initializable

createExecutorService

protected abstract java.util.concurrent.ExecutorService createExecutorService()

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

Returns:

ExecutorServiceインスタンス

getExecutorService

public java.util.concurrent.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 java.lang.InterruptedException

スレッド終了を待つ。

Returns:

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

Throws:

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

needsShutdown

protected boolean needsShutdown()

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

Returns:

必要がある場合、真

setTimeoutSecond

public void setTimeoutSecond(long timeoutSecond)

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

Parameters:

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