Package org.apache.bookkeeper.common.util

Class OrderedExecutor.AbstractBuilder<T extends OrderedExecutor>

java.lang.Object

org.apache.bookkeeper.common.util.OrderedExecutor.AbstractBuilder<T>

Direct Known Subclasses:

OrderedExecutor.Builder, OrderedScheduler.SchedulerBuilder

Enclosing class:

OrderedExecutor

public abstract static class OrderedExecutor.AbstractBuilder<T extends OrderedExecutor>
extends Object

Abstract builder class to build OrderedScheduler.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	enableBusyWait
protected boolean	enableThreadScopedMetrics
protected int	maxTasksInQueue
protected String	name
protected int	numThreads
protected boolean	preserveMdcForTaskExecution
protected StatsLogger	statsLogger
protected ThreadFactory	threadFactory
protected boolean	traceTaskExecution
protected long	warnTimeMicroSec

Constructor Summary

Constructors

Constructor	Description
AbstractBuilder()

Method Summary

Modifier and Type	Method	Description
T	build()
OrderedExecutor.AbstractBuilder<T>	enableBusyWait(boolean enableBusyWait)
OrderedExecutor.AbstractBuilder<T>	enableThreadScopedMetrics(boolean enableThreadScopedMetrics)
OrderedExecutor.AbstractBuilder<T>	maxTasksInQueue(int num)
OrderedExecutor.AbstractBuilder<T>	name(String name)
OrderedExecutor.AbstractBuilder<T>	numThreads(int num)
OrderedExecutor.AbstractBuilder<T>	preserveMdcForTaskExecution(boolean enabled)
OrderedExecutor.AbstractBuilder<T>	statsLogger(StatsLogger statsLogger)
OrderedExecutor.AbstractBuilder<T>	threadFactory(ThreadFactory threadFactory)
OrderedExecutor.AbstractBuilder<T>	traceTaskExecution(boolean enabled)
OrderedExecutor.AbstractBuilder<T>	traceTaskWarnTimeMicroSec(long warnTimeMicroSec)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

name

protected String name

numThreads

protected int numThreads

threadFactory

protected ThreadFactory threadFactory

statsLogger

protected StatsLogger statsLogger

traceTaskExecution

protected boolean traceTaskExecution

preserveMdcForTaskExecution

protected boolean preserveMdcForTaskExecution

warnTimeMicroSec

protected long warnTimeMicroSec

maxTasksInQueue

protected int maxTasksInQueue

enableBusyWait

protected boolean enableBusyWait

enableThreadScopedMetrics

protected boolean enableThreadScopedMetrics

Constructor Details

AbstractBuilder

public AbstractBuilder()

Method Details

name

public OrderedExecutor.AbstractBuilder<T> name(String name)

numThreads

public OrderedExecutor.AbstractBuilder<T> numThreads(int num)

maxTasksInQueue

public OrderedExecutor.AbstractBuilder<T> maxTasksInQueue(int num)

threadFactory

public OrderedExecutor.AbstractBuilder<T> threadFactory(ThreadFactory threadFactory)

statsLogger

public OrderedExecutor.AbstractBuilder<T> statsLogger(StatsLogger statsLogger)

traceTaskExecution

public OrderedExecutor.AbstractBuilder<T> traceTaskExecution(boolean enabled)

preserveMdcForTaskExecution

public OrderedExecutor.AbstractBuilder<T> preserveMdcForTaskExecution(boolean enabled)

traceTaskWarnTimeMicroSec

public OrderedExecutor.AbstractBuilder<T> traceTaskWarnTimeMicroSec(long warnTimeMicroSec)

enableBusyWait

public OrderedExecutor.AbstractBuilder<T> enableBusyWait(boolean enableBusyWait)

enableThreadScopedMetrics

public OrderedExecutor.AbstractBuilder<T> enableThreadScopedMetrics(boolean enableThreadScopedMetrics)

build

public T build()