sirius.kernel.async

Class AsyncExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

sirius.kernel.async.AsyncExecutor

All Implemented Interfaces:

Executor, ExecutorService, RejectedExecutionHandler

public class AsyncExecutor
extends ThreadPoolExecutor
implements RejectedExecutionHandler

Represents an executor used by sirius to schedule background tasks.

Instances of this class are created and managed by Tasks. This class is only made public so it can be accessed for statistical reasons like (getBlocked() or getDropped().

Nested Class Summary

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

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

Field Summary

Fields

Modifier and Type	Field and Description
protected Average	duration
protected Counter	executed

Method Summary

Modifier and Type	Method and Description
double	getAverageDuration() The average duration of a task in milliseconds.
long	getBlocked() The number of tasks which were executed by blocking the caller due to system overload conditions.
String	getCategory() Returns the category this executor was created for.
long	getDropped() The number of tasks dropped due to system overload conditions.
long	getExecuted() The number of tasks which were executed by this executor
void	rejectedExecution(Runnable r, ThreadPoolExecutor executor)
String	toString()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

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

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Field Detail

executed

protected Counter executed

duration

protected Average duration

Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                              ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler

toString

public String toString()

Overrides:

toString in class ThreadPoolExecutor

getCategory

public String getCategory()

Returns the category this executor was created for.

Returns:

the category of tasks this executor runs.

getExecuted

public long getExecuted()

The number of tasks which were executed by this executor

Returns:

the number of tasks executed so far

getAverageDuration

public double getAverageDuration()

The average duration of a task in milliseconds.

Returns:

the average execution time of a task in milliseconds

getBlocked

public long getBlocked()

The number of tasks which were executed by blocking the caller due to system overload conditions.

A system overload occurs if all available tasks are busy and the queue of this executor reached its limit.

Returns:

the number of blocking task executions so far.

getDropped

public long getDropped()

The number of tasks dropped due to system overload conditions.

A system overload occurs if all available tasks are busy and the queue of this executor reached its limit. If a task has a dropHandler attached, the handler is informed and the task is not executed by simply deleted.

Returns:

the number of dropped tasks so far.