Package org.openiam.concurrent

Class OpenIAMScheduledExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

org.openiam.concurrent.OpenIAMScheduledExecutorService

All Implemented Interfaces:

Executor, ExecutorService, ScheduledExecutorService

public class OpenIAMScheduledExecutorService
extends ScheduledThreadPoolExecutor

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor	Description
OpenIAMScheduledExecutorService(int corePoolSize)
OpenIAMScheduledExecutorService(int corePoolSize, RejectedExecutionHandler handler)
OpenIAMScheduledExecutorService(int corePoolSize, ThreadFactory threadFactory)
OpenIAMScheduledExecutorService(int corePoolSize, ThreadFactory threadFactory, RejectedExecutionHandler handler)

Method Summary

Modifier and Type	Method	Description
protected <V> RunnableScheduledFuture<V>	decorateTask(Runnable runnable, RunnableScheduledFuture<V> task)
protected <V> RunnableScheduledFuture<V>	decorateTask(Callable<V> callable, RunnableScheduledFuture<V> task)
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value)
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable)
void	setAuditLogSupplier(AuditLogSupplier auditLogSupplier)
void	setRequestorIDProvider(SecurityInfoProvider requestorIDProvider)

Methods inherited from class java.util.concurrent.ScheduledThreadPoolExecutor

execute, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, shutdown, shutdownNow, submit, submit, submit

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Constructor Detail

OpenIAMScheduledExecutorService

public OpenIAMScheduledExecutorService(int corePoolSize,
                                       RejectedExecutionHandler handler)

OpenIAMScheduledExecutorService

public OpenIAMScheduledExecutorService(int corePoolSize,
                                       ThreadFactory threadFactory,
                                       RejectedExecutionHandler handler)

OpenIAMScheduledExecutorService

public OpenIAMScheduledExecutorService(int corePoolSize,
                                       ThreadFactory threadFactory)

OpenIAMScheduledExecutorService

public OpenIAMScheduledExecutorService(int corePoolSize)

Method Detail

decorateTask

protected <V> RunnableScheduledFuture<V> decorateTask(Runnable runnable,
                                                      RunnableScheduledFuture<V> task)

Overrides:

decorateTask in class ScheduledThreadPoolExecutor

decorateTask

protected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> callable,
                                                      RunnableScheduledFuture<V> task)

Overrides:

decorateTask in class ScheduledThreadPoolExecutor

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable,
                                           T value)

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable)

Overrides:

newTaskFor in class AbstractExecutorService

setRequestorIDProvider

public void setRequestorIDProvider(SecurityInfoProvider requestorIDProvider)

setAuditLogSupplier

public void setAuditLogSupplier(AuditLogSupplier auditLogSupplier)