Package net.datenwerke.async

Class DwAsyncServiceImpl

java.lang.Object

net.datenwerke.async.DwAsyncServiceImpl

All Implemented Interfaces:

DwAsyncService

public class DwAsyncServiceImpl
extends Object
implements DwAsyncService

Constructor Summary

Constructors

Constructor	Description
DwAsyncServiceImpl(Long waitBeforeForcedShutdown)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTerminationForPool(String poolToken, long timeout, TimeUnit unit)	Blocks until all tasks have completed execution after a shutdown request for the given pool
int	getActiveCountAll()	Returns the approximately number of active threads in all pools.
long	getCompletedTaskCountAll()	Returns the approximate total number of tasks that have completed execution summed over all pools.
int	getNrOfPools()	Returns the number of pools
DwAsyncPool	getPool(String poolToken)	Returns the pool identified by poolToken or null.
long	getTaskCountAll()	Returns the approximate total number of tasks that have ever been scheduled for execution summed over all pools.
DwAsyncPool	initPool(String poolToken, PoolConfiguration configuration)	Initializes a new pool for the given configuration.
boolean	isShutdownPool(String poolToken)	Returns true if the pool was asked to shutdown.
boolean	isTerminatedPool(String poolToken)	Returns true if all tasks have completed following shut down.
boolean	poolExists(String poolToken)	Returns true if pool identified by poolToken exists
void	shutdownAll()	Calls shutdown on all pools.
List<Runnable>	shutdownAllNow()	Calls shutdownNow on all pools.
List<Runnable>	shutdownNowDefault()	Terminates the default thread pool.
void	shutdownPool(String poolToken)	If pool exists, the pool is asked to orderly shutdown.
List<Runnable>	shutdownPoolNow(String poolToken)	If pool exists, the pool is shutdown immediately.
void	submit(Runnable task)	Submits a task to be run on the default thread pool
void	suhtdownDefault()	Shuts down the default thread pool

Methods inherited from class java.lang.Object

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

Constructor Details

DwAsyncServiceImpl

public DwAsyncServiceImpl(Long waitBeforeForcedShutdown)

Method Details

shutdownAll

public void shutdownAll()

Description copied from interface: DwAsyncService

Calls shutdown on all pools.

Specified by:

shutdownAll in interface DwAsyncService

See Also:

• DwAsyncPool.shutdown()

shutdownAllNow

public List<Runnable> shutdownAllNow()

Description copied from interface: DwAsyncService

Calls shutdownNow on all pools.

Specified by:

shutdownAllNow in interface DwAsyncService

See Also:

• DwAsyncPool.shutdownNow()

poolExists

public boolean poolExists(String poolToken)

Description copied from interface: DwAsyncService

Returns true if pool identified by poolToken exists

Specified by:

poolExists in interface DwAsyncService

Parameters:

poolToken - The pool identifier

isShutdownPool

public boolean isShutdownPool(String poolToken)

Description copied from interface: DwAsyncService

Returns true if the pool was asked to shutdown.

Specified by:

isShutdownPool in interface DwAsyncService

Parameters:

poolToken -

See Also:

• ExecutorService.isShutdown()

isTerminatedPool

public boolean isTerminatedPool(String poolToken)

Description copied from interface: DwAsyncService

Returns true if all tasks have completed following shut down.

Specified by:

isTerminatedPool in interface DwAsyncService

Parameters:

poolToken -

initPool

public DwAsyncPool initPool(String poolToken,
 PoolConfiguration configuration)

Description copied from interface: DwAsyncService

Initializes a new pool for the given configuration. If a pool for poolToken already exists, the old pool is terminated.

Specified by:

initPool in interface DwAsyncService

Parameters:

poolToken -

configuration -

Returns:

The pool

getPool

public DwAsyncPool getPool(String poolToken)

Description copied from interface: DwAsyncService

Returns the pool identified by poolToken or null.

Specified by:

getPool in interface DwAsyncService

Parameters:

poolToken -

shutdownPool

public void shutdownPool(String poolToken)

Description copied from interface: DwAsyncService

If pool exists, the pool is asked to orderly shutdown.

Specified by:

shutdownPool in interface DwAsyncService

Parameters:

poolToken -

See Also:

• ExecutorService.shutdown()

shutdownPoolNow

public List<Runnable> shutdownPoolNow(String poolToken)

Description copied from interface: DwAsyncService

If pool exists, the pool is shutdown immediately.

Specified by:

shutdownPoolNow in interface DwAsyncService

Parameters:

poolToken -

Returns:

list of tasks that never commenced execution

See Also:

• ExecutorService.shutdownNow()

awaitTerminationForPool

public boolean awaitTerminationForPool(String poolToken,
 long timeout,
 TimeUnit unit)
                                throws InterruptedException

Description copied from interface: DwAsyncService

Blocks until all tasks have completed execution after a shutdown request for the given pool

Specified by:

awaitTerminationForPool in interface DwAsyncService

Parameters:

poolToken - The pool identifier

timeout -

unit -

Throws:

InterruptedException

See Also:

• ExecutorService.awaitTermination(long, TimeUnit)

getNrOfPools

public int getNrOfPools()

Description copied from interface: DwAsyncService

Returns the number of pools

Specified by:

getNrOfPools in interface DwAsyncService

Returns:

the number of pools

getActiveCountAll

public int getActiveCountAll()

Description copied from interface: DwAsyncService

Returns the approximately number of active threads in all pools.

Specified by:

getActiveCountAll in interface DwAsyncService

Returns:

the number of threads

getTaskCountAll

public long getTaskCountAll()

Description copied from interface: DwAsyncService

Returns the approximate total number of tasks that have ever been scheduled for execution summed over all pools.

Specified by:

getTaskCountAll in interface DwAsyncService

Returns:

The number of tasks

getCompletedTaskCountAll

public long getCompletedTaskCountAll()

Description copied from interface: DwAsyncService

Returns the approximate total number of tasks that have completed execution summed over all pools.

Specified by:

getCompletedTaskCountAll in interface DwAsyncService

Returns:

the number of tasks

submit

public void submit(Runnable task)

Description copied from interface: DwAsyncService

Submits a task to be run on the default thread pool

Specified by:

submit in interface DwAsyncService

Parameters:

task -

suhtdownDefault

public void suhtdownDefault()

Description copied from interface: DwAsyncService

Shuts down the default thread pool

Specified by:

suhtdownDefault in interface DwAsyncService

shutdownNowDefault

public List<Runnable> shutdownNowDefault()

Description copied from interface: DwAsyncService

Terminates the default thread pool.

Specified by:

shutdownNowDefault in interface DwAsyncService