ambit2.rest.task

Class TaskStorage<USERID>

java.lang.Object

ambit2.rest.task.TaskStorage<USERID>

All Implemented Interfaces:

net.idea.restnet.i.task.ITaskStorage<USERID>

public class TaskStorage<USERID>
extends Object
implements net.idea.restnet.i.task.ITaskStorage<USERID>

Field Summary

Fields

Modifier and Type	Field and Description
protected ScheduledThreadPoolExecutor	cleanupCompletedTasks
protected ScheduledThreadPoolExecutor	cleanupTimer
protected ExecutorCompletionService<org.restlet.data.Reference>	completionService_external
protected ExecutorCompletionService<org.restlet.data.Reference>	completionService_internal
protected double	cputime
protected double	cpuutilisation
protected Logger	logger
protected String	name
protected ExecutorService	pool_external
protected ExecutorService	pool_internal
protected long	taskCleanupRate
protected TimeUnit	taskCleanupUnit
protected ConcurrentMap<UUID,net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID>>	tasks
protected double	waittime

Constructor Summary

Constructors

Constructor and Description
TaskStorage(String name, Logger logger)

Method Summary

Modifier and Type	Method and Description
net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID>	addTask(String taskName, net.idea.restnet.i.task.ICallableTask callable, org.restlet.data.Reference baseReference, USERID user, boolean internal)
void	cancelTasks()
void	cleanUpTasks()
protected ExecutorService	createExecutorService(String name, int maxThreads)
protected net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID>	createTask(USERID user, net.idea.restnet.i.task.ICallableTask callable)
Iterator<net.idea.restnet.i.task.ITask<org.restlet.data.Reference,USERID>>	filterTasks()
net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID>	findTask(String id)
net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID>	findTask(UUID id)
Iterator<UUID>	getTasks()
void	removeTask(String id)
void	removeTasks()
void	shutdown(long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected transient Logger logger

name

protected String name

taskCleanupUnit

protected TimeUnit taskCleanupUnit

taskCleanupRate

protected long taskCleanupRate

cpuutilisation

protected double cpuutilisation

waittime

protected double waittime

cputime

protected double cputime

completionService_internal

protected ExecutorCompletionService<org.restlet.data.Reference> completionService_internal

completionService_external

protected ExecutorCompletionService<org.restlet.data.Reference> completionService_external

pool_internal

protected ExecutorService pool_internal

pool_external

protected ExecutorService pool_external

cleanupTimer

protected ScheduledThreadPoolExecutor cleanupTimer

cleanupCompletedTasks

protected ScheduledThreadPoolExecutor cleanupCompletedTasks

tasks

protected ConcurrentMap<UUID,net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID>> tasks

Constructor Detail

TaskStorage

public TaskStorage(String name,
                   Logger logger)

Method Detail

cleanUpTasks

public void cleanUpTasks()

createExecutorService

protected ExecutorService createExecutorService(String name,
                                                int maxThreads)

createTask

protected net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID> createTask(USERID user,
                                                                                               net.idea.restnet.i.task.ICallableTask callable)

addTask

public net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID> addTask(String taskName,
                                                                                         net.idea.restnet.i.task.ICallableTask callable,
                                                                                         org.restlet.data.Reference baseReference,
                                                                                         USERID user,
                                                                                         boolean internal)

Specified by:

addTask in interface net.idea.restnet.i.task.ITaskStorage<USERID>

findTask

public net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID> findTask(String id)

Specified by:

findTask in interface net.idea.restnet.i.task.ITaskStorage<USERID>

findTask

public net.idea.restnet.i.task.ITask<net.idea.restnet.i.task.ITaskResult,USERID> findTask(UUID id)

Specified by:

findTask in interface net.idea.restnet.i.task.ITaskStorage<USERID>

removeTask

public void removeTask(String id)

getTasks

public Iterator<UUID> getTasks()

Specified by:

getTasks in interface net.idea.restnet.i.task.ITaskStorage<USERID>

removeTasks

public void removeTasks()

Specified by:

removeTasks in interface net.idea.restnet.i.task.ITaskStorage<USERID>

cancelTasks

public void cancelTasks()

shutdown

public void shutdown(long timeout,
                     TimeUnit unit)
              throws Exception

Specified by:

shutdown in interface net.idea.restnet.i.task.ITaskStorage<USERID>

Throws:

Exception

filterTasks

public Iterator<net.idea.restnet.i.task.ITask<org.restlet.data.Reference,USERID>> filterTasks()

Specified by:

filterTasks in interface net.idea.restnet.i.task.ITaskStorage<USERID>