Uses of Interface
org.apache.cassandra.concurrent.ExecutorBuilder
Packages that use ExecutorBuilder
-
Uses of ExecutorBuilder in org.apache.cassandra.concurrent
Classes in org.apache.cassandra.concurrent that implement ExecutorBuilderModifier and TypeClassDescriptionclassThreadPoolExecutorBuilder<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 ExecutorBuilderModifier and TypeMethodDescriptionExecutorBuilder<? extends E>ExecutorBuilderFactory.configurePooled(String name, int threads) Configure a pooled executor with the requested number of threadsExecutorFactory.Default.configurePooled(String name, int threads) ExecutorBuilder<? extends S>ExecutorBuilderFactory.configureSequential(String name) Configure a sequential (single threaded) executorExecutorFactory.Default.configureSequential(String name) ExecutorBuilder.withDefaultThreadGroup()Use the system default thread group for the threads we create.ThreadPoolExecutorBuilder.withDefaultThreadGroup()ExecutorBuilder.withKeepAlive()Core threads for the executor built by this factory will never timeout (default for single threaded builders).ExecutorBuilder.withKeepAlive(long keepAlive, TimeUnit keepAliveUnits) Threads for the executor built by this factory will timeout (terminate) after the specified period.ExecutorBuilder.withQueueLimit(int queueLimit) The executor built by this factory will limit the number of queued tasks; default is unlimited.ExecutorBuilder.withRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler) Set theRejectedExecutionHandlerfor the executor built by this factory.ExecutorBuilder.withThreadGroup(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.ThreadPoolExecutorBuilder.withThreadGroup(ThreadGroup threadGroup) ExecutorBuilder.withThreadPriority(int threadPriority) Specify the priority of threads that service the executor built by this factory (default toThread.NORM_PRIORITY)ExecutorBuilder.withUncaughtExceptionHandler(Thread.UncaughtExceptionHandler uncaughtExceptionHandler) Set theThread.UncaughtExceptionHandlerfor threads that service executors built by this factory.