de.fraunhofer.igd.klarschiff.service.job

Class JobExecutorService

java.lang.Object

de.fraunhofer.igd.klarschiff.service.job.JobExecutorService

@Service
public class JobExecutorService
extends Object

Die Klasse stellt einen Service zum Ausführen von Jobs bereit. Die Jobs werden dabei durch eine Pool verwaltet, so dass nicht beliebig viele Jobs zur gleichen Zeit ausgeführt werden. Dieses wird beispielsweise für das Versenden von E-Mails verwendet.

Author:

Stefan Audersch (Fraunhofer IGD)

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	corePoolSize
(package private) long	keepAliveTime
(package private) int	maxPoolSize
(package private) ThreadPoolExecutor	threadPool
(package private) ArrayBlockingQueue<Runnable>	workQueue

Constructor Summary

Constructors

Constructor and Description
JobExecutorService()

Method Summary

Modifier and Type	Method and Description
int	getCorePoolSize()
long	getKeepAliveTime()
int	getmaxPoolSize()
void	init() Initialisierung der Queue und des Pools
void	runJob(Runnable job) Ausführen eines Jobs im Pool
void	setCorePoolSize(int corePoolSize)
void	setKeepAliveTime(long keepAliveTime)
void	setmaxPoolSize(int maxPoolSize)
void	stop() Stoppen des Pools.

Methods inherited from class java.lang.Object

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

Field Detail

corePoolSize

int corePoolSize

maxPoolSize

int maxPoolSize

keepAliveTime

long keepAliveTime

threadPool

ThreadPoolExecutor threadPool

workQueue

ArrayBlockingQueue<Runnable> workQueue

Constructor Detail

JobExecutorService

public JobExecutorService()

Method Detail

init

@PostConstruct
public void init()

Initialisierung der Queue und des Pools

stop

@PreDestroy
public void stop()

Stoppen des Pools.

runJob

public void runJob(Runnable job)

Ausführen eines Jobs im Pool

Parameters:

job - Job, der ausgeführt werden soll.

getCorePoolSize

public int getCorePoolSize()

setCorePoolSize

public void setCorePoolSize(int corePoolSize)

getmaxPoolSize

public int getmaxPoolSize()

setmaxPoolSize

public void setmaxPoolSize(int maxPoolSize)

getKeepAliveTime

public long getKeepAliveTime()

setKeepAliveTime

public void setKeepAliveTime(long keepAliveTime)