Package org.noise_planet.noisemodelling.webserver.script

Class JobExecutorService

java.lang.Object

org.noise_planet.noisemodelling.webserver.script.JobExecutorService

public class JobExecutorService
extends Object

Manage pool of Job Threads.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ExecutorService	executorService
protected final Map<Integer,Job<?>>	jobs

Constructor Summary

Constructors

Constructor	Description
JobExecutorService(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit)

Method Summary

Modifier and Type	Method	Description
boolean	cancelJob(int jobId)	Cancel a job
Job<?>	getJob(int id)
Job<?>	removeJob(int jobId)	Remove a job from the service.
void	shutdown()
<T> Future<T>	submitJob(Job<T> job)

Methods inherited from class java.lang.Object

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

Field Details

jobs

protected final Map<Integer,Job<?>> jobs

executorService

protected final ExecutorService executorService

Constructor Details

JobExecutorService

public JobExecutorService(int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
 @NotNull
 TimeUnit unit)

Method Details

submitJob

public <T> Future<T> submitJob(Job<T> job)

getJob

public Job<?> getJob(int id)

Parameters:

id - Job identifier

Returns:

The job instance or null if it does not exist

cancelJob

public boolean cancelJob(int jobId)

Cancel a job

Parameters:

jobId - Job identifier

Returns:

true if the job was found and canceled, false otherwise

removeJob

public Job<?> removeJob(int jobId)

Remove a job from the service. This does not cancel the job if it is still running, it just removes it from the tracking map. See cancelJob(int jobId) to cancel a job before removing it.

Parameters:

jobId - Job identifier

Returns:

The removed job instance or null if it did not exist

shutdown

public void shutdown()