com.orientechnologies.common.thread

Class OScheduledThreadPoolExecutorWithLogging

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

com.orientechnologies.common.thread.OScheduledThreadPoolExecutorWithLogging

All Implemented Interfaces:

Executor, ExecutorService, ScheduledExecutorService

public class OScheduledThreadPoolExecutorWithLogging
extends ScheduledThreadPoolExecutor

The same as thread ScheduledThreadPoolExecutor but also logs all exceptions happened inside of the tasks which caused tasks to stop.

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 and Description
OScheduledThreadPoolExecutorWithLogging(int corePoolSize)
OScheduledThreadPoolExecutorWithLogging(int corePoolSize, RejectedExecutionHandler handler)
OScheduledThreadPoolExecutorWithLogging(int corePoolSize, ThreadFactory threadFactory)
OScheduledThreadPoolExecutorWithLogging(int corePoolSize, ThreadFactory threadFactory, RejectedExecutionHandler handler)

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t)

Methods inherited from class java.util.concurrent.ScheduledThreadPoolExecutor

decorateTask, decorateTask, 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

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, newTaskFor, newTaskFor

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

OScheduledThreadPoolExecutorWithLogging

public OScheduledThreadPoolExecutorWithLogging(int corePoolSize)

OScheduledThreadPoolExecutorWithLogging

public OScheduledThreadPoolExecutorWithLogging(int corePoolSize,
                                               ThreadFactory threadFactory)

OScheduledThreadPoolExecutorWithLogging

public OScheduledThreadPoolExecutorWithLogging(int corePoolSize,
                                               RejectedExecutionHandler handler)

OScheduledThreadPoolExecutorWithLogging

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

Method Detail

afterExecute

protected void afterExecute(Runnable r,
                            Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor