Uses of Interface
org.apache.cassandra.concurrent.ExecutorBuilder
-
Packages that use ExecutorBuilder Package Description org.apache.cassandra.concurrent -
-
Uses of ExecutorBuilder in org.apache.cassandra.concurrent
Classes in org.apache.cassandra.concurrent that implement ExecutorBuilder Modifier and Type Class Description classThreadPoolExecutorBuilder<E extends ExecutorPlus>Configure aThreadPoolExecutorPlus, applying Cassandra's best practices by default Core threads may timeout, and use a defaultThreadPoolExecutorBuilder.keepAlivetime inThreadPoolExecutorBuilder.keepAliveUnitsThreads share the sameThreadGroup, which may be configurably a child of a specifiedThreadGroupdescended from the same parent of theNamedThreadFactory.MetaFactoryBy default queues are unbounded in length The defaultRejectedExecutionHandleris implementation dependent, but may be overridden The defaultThread.UncaughtExceptionHandleris inherited fromNamedThreadFactory.MetaFactory, which in turn receives it from theExecutorBuilderFactoryMethods in org.apache.cassandra.concurrent that return ExecutorBuilder Modifier and Type Method Description ExecutorBuilder<? extends E>ExecutorBuilderFactory. configurePooled(java.lang.String name, int threads)Configure a pooled executor with the requested number of threadsExecutorBuilder<ThreadPoolExecutorPlus>ExecutorFactory.Default. configurePooled(java.lang.String name, int threads)ExecutorBuilder<? extends S>ExecutorBuilderFactory. configureSequential(java.lang.String name)Configure a sequential (single threaded) executorExecutorBuilder<SingleThreadExecutorPlus>ExecutorFactory.Default. configureSequential(java.lang.String name)ExecutorBuilder<E>ExecutorBuilder. withDefaultThreadGroup()Use the system default thread group for the threads we create.ExecutorBuilder<E>ThreadPoolExecutorBuilder. withDefaultThreadGroup()ExecutorBuilder<E>ExecutorBuilder. withKeepAlive()Core threads for the executor built by this factory will never timeout (default for single threaded builders).ExecutorBuilder<E>ExecutorBuilder. withKeepAlive(long keepAlive, java.util.concurrent.TimeUnit keepAliveUnits)Threads for the executor built by this factory will timeout (terminate) after the specified period.ExecutorBuilder<E>ExecutorBuilder. withQueueLimit(int queueLimit)The executor built by this factory will limit the number of queued tasks; default is unlimited.ExecutorBuilder<E>ExecutorBuilder. withRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)Set theRejectedExecutionHandlerfor the executor built by this factory.ExecutorBuilder<E>ExecutorBuilder. withThreadGroup(java.lang.ThreadGroup threadGroup)Threads for the executor built by this factory will all be (transitively) members ofthreadGroup, but may directly reside in a child thread group.ExecutorBuilder<E>ThreadPoolExecutorBuilder. withThreadGroup(java.lang.ThreadGroup threadGroup)ExecutorBuilder<E>ExecutorBuilder. withThreadPriority(int threadPriority)Specify the priority of threads that service the executor built by this factory (default toThread.NORM_PRIORITY)ExecutorBuilder<E>ExecutorBuilder. withUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler uncaughtExceptionHandler)Set theThread.UncaughtExceptionHandlerfor threads that service executors built by this factory.
-