Package org.apache.pekko.dispatch

Class ThreadPoolConfigBuilder

java.lang.Object

org.apache.pekko.dispatch.ThreadPoolConfigBuilder

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public final class ThreadPoolConfigBuilder
extends Object
implements scala.Product, Serializable

A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ThreadPoolConfigBuilder(ThreadPoolConfig config)

Method Summary

Modifier and Type	Method	Description
static ThreadPoolConfigBuilder	apply(ThreadPoolConfig config)
boolean	canEqual(Object x$1)
ThreadPoolConfig	config()
ThreadPoolConfigBuilder	configure(scala.collection.immutable.Seq<scala.Option<scala.Function1<ThreadPoolConfigBuilder,ThreadPoolConfigBuilder>>> fs)
ThreadPoolConfigBuilder	copy(ThreadPoolConfig config)
ThreadPoolConfig	copy$default$1()
boolean	equals(Object x$1)
int	hashCode()
ThreadPoolConfigBuilder	isVirtualized(boolean isVirtualized)
int	productArity()
Object	productElement(int x$1)
String	productElementName(int x$1)
scala.collection.Iterator<Object>	productIterator()
String	productPrefix()
ThreadPoolConfigBuilder	setAllowCoreThreadTimeout(boolean allow)
ThreadPoolConfigBuilder	setCorePoolSize(int size)
ThreadPoolConfigBuilder	setCorePoolSizeFromFactor(int min, double multiplier, int max)
ThreadPoolConfigBuilder	setFixedPoolSize(int size)
ThreadPoolConfigBuilder	setKeepAliveTime(scala.concurrent.duration.Duration time)
ThreadPoolConfigBuilder	setKeepAliveTimeInMillis(long time)
ThreadPoolConfigBuilder	setMaxPoolSize(int size)
ThreadPoolConfigBuilder	setMaxPoolSizeFromFactor(int min, double multiplier, int max)
ThreadPoolConfigBuilder	setQueueFactory(scala.Function0<BlockingQueue<Runnable>> newQueueFactory)
String	toString()
static scala.Option<ThreadPoolConfig>	unapply(ThreadPoolConfigBuilder x$0)
ThreadPoolConfigBuilder	withNewThreadPoolWithArrayBlockingQueueWithCapacityAndFairness(int capacity, boolean fair)
ThreadPoolConfigBuilder	withNewThreadPoolWithCustomBlockingQueue(BlockingQueue<Runnable> queue)
ThreadPoolConfigBuilder	withNewThreadPoolWithCustomBlockingQueue(scala.Function0<BlockingQueue<Runnable>> newQueueFactory)
ThreadPoolConfigBuilder	withNewThreadPoolWithLinkedBlockingQueueWithCapacity(int capacity)
ThreadPoolConfigBuilder	withNewThreadPoolWithLinkedBlockingQueueWithUnboundedCapacity()
ThreadPoolConfigBuilder	withNewThreadPoolWithSynchronousQueueWithFairness(boolean fair)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Product

productElementNames

Constructor Details

ThreadPoolConfigBuilder

public ThreadPoolConfigBuilder(ThreadPoolConfig config)

Method Details

apply

public static ThreadPoolConfigBuilder apply(ThreadPoolConfig config)

unapply

public static scala.Option<ThreadPoolConfig> unapply(ThreadPoolConfigBuilder x$0)

config

public ThreadPoolConfig config()

withNewThreadPoolWithCustomBlockingQueue

public ThreadPoolConfigBuilder withNewThreadPoolWithCustomBlockingQueue(scala.Function0<BlockingQueue<Runnable>> newQueueFactory)

withNewThreadPoolWithCustomBlockingQueue

public ThreadPoolConfigBuilder withNewThreadPoolWithCustomBlockingQueue(BlockingQueue<Runnable> queue)

withNewThreadPoolWithLinkedBlockingQueueWithUnboundedCapacity

public ThreadPoolConfigBuilder withNewThreadPoolWithLinkedBlockingQueueWithUnboundedCapacity()

withNewThreadPoolWithLinkedBlockingQueueWithCapacity

public ThreadPoolConfigBuilder withNewThreadPoolWithLinkedBlockingQueueWithCapacity(int capacity)

withNewThreadPoolWithSynchronousQueueWithFairness

public ThreadPoolConfigBuilder withNewThreadPoolWithSynchronousQueueWithFairness(boolean fair)

withNewThreadPoolWithArrayBlockingQueueWithCapacityAndFairness

public ThreadPoolConfigBuilder withNewThreadPoolWithArrayBlockingQueueWithCapacityAndFairness(int capacity,
 boolean fair)

setFixedPoolSize

public ThreadPoolConfigBuilder setFixedPoolSize(int size)

setCorePoolSize

public ThreadPoolConfigBuilder setCorePoolSize(int size)

setMaxPoolSize

public ThreadPoolConfigBuilder setMaxPoolSize(int size)

setCorePoolSizeFromFactor

public ThreadPoolConfigBuilder setCorePoolSizeFromFactor(int min,
 double multiplier,
 int max)

setMaxPoolSizeFromFactor

public ThreadPoolConfigBuilder setMaxPoolSizeFromFactor(int min,
 double multiplier,
 int max)

setKeepAliveTimeInMillis

public ThreadPoolConfigBuilder setKeepAliveTimeInMillis(long time)

setKeepAliveTime

public ThreadPoolConfigBuilder setKeepAliveTime(scala.concurrent.duration.Duration time)

setAllowCoreThreadTimeout

public ThreadPoolConfigBuilder setAllowCoreThreadTimeout(boolean allow)

setQueueFactory

public ThreadPoolConfigBuilder setQueueFactory(scala.Function0<BlockingQueue<Runnable>> newQueueFactory)

isVirtualized

public ThreadPoolConfigBuilder isVirtualized(boolean isVirtualized)

configure

public ThreadPoolConfigBuilder configure(scala.collection.immutable.Seq<scala.Option<scala.Function1<ThreadPoolConfigBuilder,ThreadPoolConfigBuilder>>> fs)

copy

public ThreadPoolConfigBuilder copy(ThreadPoolConfig config)

copy$default$1

public ThreadPoolConfig copy$default$1()

productPrefix

public String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(Object x$1)

Specified by:

canEqual in interface scala.Equals

productElementName

public String productElementName(int x$1)

Specified by:

productElementName in interface scala.Product

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class Object