icy.system.thread

Class InstanceProcessor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

icy.system.thread.Processor

icy.system.thread.InstanceProcessor

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

Direct Known Subclasses:

SingleInstanceProcessor

public class InstanceProcessor
extends Processor

Single instance processor.
It allows to run processes on a thread and verify the constraint that only one single instance of a specific process can be queued at a given time.

Nested Class Summary

Nested classes/interfaces inherited from class icy.system.thread.Processor

Processor.ProcessorEventListener

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

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields inherited from class icy.system.thread.Processor

DEFAULT_MAX_PROCESSING, DEFAULT_MAX_WAITING, MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
InstanceProcessor() Create an InstanceProcessor
InstanceProcessor(int priority) Create an InstanceProcessor
InstanceProcessor(int maxWaiting, int priority) Create an InstanceProcessor

Method Summary

Methods inherited from class icy.system.thread.Processor

addListener, addTask, addTask, addTask, execute, fireDoneEvent, getDefaultThreadName, getFreeSlotNumber, getPriority, getThreadName, getWaitingTasksCount, getWaitingTasksCount, getWaitingTasksCount, getWaitingTasksCount, hasWaitingTasks, hasWaitingTasks, hasWaitingTasks, hasWaitingTasks, isFull, isProcessing, limitWaitingTask, limitWaitingTask, limitWaitingTask, remove, removeAllWaitingTasks, removeFirstWaitingTask, removeFirstWaitingTask, removeFirstWaitingTask, removeListener, removeTask, removeWaitingTasks, removeWaitingTasks, removeWaitingTasks, setDefaultThreadName, setPriority, setThreadName, shutdownAndWait, submit, submit, submit, submit, submit, submit, submit, submit, submit, waitAll

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

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

Constructor Detail

InstanceProcessor

public InstanceProcessor(int maxWaiting,
                 int priority)

Create an InstanceProcessor

InstanceProcessor

public InstanceProcessor(int priority)

Create an InstanceProcessor

InstanceProcessor

public InstanceProcessor()

Create an InstanceProcessor