org.apache.activemq.store.kahadb
Class KahaDBStore.StoreTaskExecutor

java.lang.Object
  extended by java.util.concurrent.AbstractExecutorService
      extended by java.util.concurrent.ThreadPoolExecutor
          extended by org.apache.activemq.store.kahadb.KahaDBStore.StoreTaskExecutor
All Implemented Interfaces:
Executor, ExecutorService
Enclosing class:
KahaDBStore

public class KahaDBStore.StoreTaskExecutor
extends ThreadPoolExecutor


Nested Class Summary
 
Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
 
Constructor Summary
KahaDBStore.StoreTaskExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit timeUnit, BlockingQueue<Runnable> queue, ThreadFactory threadFactory)
           
 
Method Summary
protected  void afterExecute(Runnable runnable, Throwable throwable)
           
 
Methods inherited from class java.util.concurrent.ThreadPoolExecutor
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, toString, wait, wait, wait
 

Constructor Detail

KahaDBStore.StoreTaskExecutor

public KahaDBStore.StoreTaskExecutor(int corePoolSize,
                                     int maximumPoolSize,
                                     long keepAliveTime,
                                     TimeUnit timeUnit,
                                     BlockingQueue<Runnable> queue,
                                     ThreadFactory threadFactory)
Method Detail

afterExecute

protected void afterExecute(Runnable runnable,
                            Throwable throwable)
Overrides:
afterExecute in class ThreadPoolExecutor


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.