Package digilib.util

Class DigilibJobCenter<V>

java.lang.Object

digilib.util.DigilibJobCenter<V>

public class DigilibJobCenter<V>
extends Object

Wrapper around ExecutionService.

Author:

casties

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	logger	general logger for this class

Constructor Summary

Constructors

Constructor	Description
DigilibJobCenter(int maxThreads, int maxQueueLen, boolean prestart, String label)	Create a DigilibJobcenter with the given number of threads and queue length.

Method Summary

Modifier and Type	Method	Description
int	getMaxQueueLen()
int	getMaxThreads()
int	getRunningJobs()	Returns the number of currently running jobs.
int	getWaitingJobs()	Returns the number of currently waiting jobs.
boolean	isBusy()	Returns if the service is overloaded.
void	setMaxQueueLen(int maxQueueLen)
void	setMaxThreads(int maxThreads)
List<Runnable>	shutdownNow()	Shuts down the Executor.
Future<?>	submit(Runnable job)	Submit Runnable job to execute.
Future<V>	submit(Callable<V> job)	Submit Callable job that returns a Value to execute.

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

general logger for this class

Constructor Details

DigilibJobCenter

public DigilibJobCenter(int maxThreads,
 int maxQueueLen,
 boolean prestart,
 String label)

Create a DigilibJobcenter with the given number of threads and queue length. If prestart=true it starts the threads in the thread pool.

Parameters:

maxThreads - the max threads

maxQueueLen - the max queue length

prestart - the prestart

label - the label

Method Details

submit

public Future<V> submit(Callable<V> job)

Submit Callable job that returns a Value to execute.

Parameters:

job - the Callable

Returns:

Future to control the job

submit

public Future<?> submit(Runnable job)

Submit Runnable job to execute.

Parameters:

job - the Runnable

Returns:

Future to control the job

isBusy

public boolean isBusy()

Returns if the service is overloaded.

Returns:

true if busy

getRunningJobs

public int getRunningJobs()

Returns the number of currently running jobs.

Returns:

the number of running jobs

getWaitingJobs

public int getWaitingJobs()

Returns the number of currently waiting jobs.

Returns:

the number of waiting jobs

setMaxThreads

public void setMaxThreads(int maxThreads)

Parameters:

maxThreads - the max threads

getMaxThreads

public int getMaxThreads()

Returns:

the max threads

setMaxQueueLen

public void setMaxQueueLen(int maxQueueLen)

Parameters:

maxQueueLen - the max queue length

getMaxQueueLen

public int getMaxQueueLen()

Returns:

the max queue length

shutdownNow

public List<Runnable> shutdownNow()

Shuts down the Executor. Tries to stop running threads and returns a list of waiting threads.

Returns:

list of waiting tasks