org.oddjob.framework.util

Class AsyncExecutionSupport

java.lang.Object

org.oddjob.framework.util.AsyncExecutionSupport

public class AsyncExecutionSupport
extends java.lang.Object

Helper class for things that execute jobs in parallel. This class ensures that all simultaneous executions are tracked, can be stopped, can be waited for and allows an action to be run on completion of all the simultaneous jobs.

See Also:

SimultaneousStructural

Author:

rob

Constructor Summary

Constructors

Constructor and Description
AsyncExecutionSupport(java.lang.Runnable onCompleteAction) Create a new instance.

Method Summary

Modifier and Type	Method and Description
void	cancelAllPendingJobs() Cancel all pending jobs.
void	joinOnAllJobs()
void	reset() Reset the internal state so that it can be used again with a new set of jobs.
int	size() The number of simultaneous job currently being tracked.
void	startWatchingJobs() Start watching jobs for them to finish executing.
void	submitJob(java.util.concurrent.ExecutorService executorService, java.lang.Runnable job)

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncExecutionSupport

public AsyncExecutionSupport(java.lang.Runnable onCompleteAction)

Create a new instance.

Parameters:

onCompleteAction -

Method Detail

submitJob

public void submitJob(java.util.concurrent.ExecutorService executorService,
                      java.lang.Runnable job)

joinOnAllJobs

public void joinOnAllJobs()
                   throws java.lang.InterruptedException,
                          java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

startWatchingJobs

public void startWatchingJobs()

Start watching jobs for them to finish executing.

cancelAllPendingJobs

public void cancelAllPendingJobs()

Cancel all pending jobs. This will not stop jobs already executing but will cancel pending jobs. Stopping jobs is left to calling code.

Also stop watching executing jobs.

reset

public void reset()

Reset the internal state so that it can be used again with a new set of jobs.

size

public int size()

The number of simultaneous job currently being tracked.

Returns: