votorola.g.util.concurrent

Class ScheduledThreadPoolExecutorX

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

ScheduledThreadPoolExecutorX

All Implemented Interfaces:

Executor, ExecutorService, ScheduledExecutorService

@ThreadSafe
public final class ScheduledThreadPoolExecutorX
extends ScheduledThreadPoolExecutor

An extended 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 and Description
ScheduledThreadPoolExecutorX(int _corePoolSize, ThreadFactory _threadFactory) Constructs a ScheduledThreadPoolExecutorX with a no-op catcher.
ScheduledThreadPoolExecutorX(int _corePoolSize, ThreadFactory _threadFactory, Catcher<Runnable> _catcher) Constructs a ScheduledThreadPoolExecutorX.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t)
Catcher<Runnable>	catcher() The catcher for all execution exceptions.

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

ScheduledThreadPoolExecutorX

public ScheduledThreadPoolExecutorX(int _corePoolSize,
                            ThreadFactory _threadFactory)

Constructs a ScheduledThreadPoolExecutorX with a no-op catcher.

See Also:

ThreadPoolExecutor.getCorePoolSize(), ThreadPoolExecutor.getThreadFactory(), catcher()

ScheduledThreadPoolExecutorX

public ScheduledThreadPoolExecutorX(int _corePoolSize,
                            ThreadFactory _threadFactory,
                            Catcher<Runnable> _catcher)

Constructs a ScheduledThreadPoolExecutorX.

See Also:

ThreadPoolExecutor.getCorePoolSize(), ThreadPoolExecutor.getThreadFactory(), catcher()

Method Detail

catcher

public Catcher<Runnable> catcher()

The catcher for all execution exceptions. Normally, it ought not to rethrow whatever is caught, because the executor will already be aware of it.

afterExecute

protected void afterExecute(Runnable r,
                Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor