Package org.apache.pekko.dispatch

Class ThreadPoolConfig

java.lang.Object

org.apache.pekko.dispatch.ThreadPoolConfig

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

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

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ThreadPoolConfig(boolean allowCorePoolTimeout, int corePoolSize, int maxPoolSize, scala.concurrent.duration.Duration threadTimeout, scala.Function0<BlockingQueue<Runnable>> queueFactory, RejectedExecutionHandler rejectionPolicy, boolean isVirtualized)

Method Summary

Modifier and Type	Method	Description
static boolean	$lessinit$greater$default$1()	INTERNAL API
static int	$lessinit$greater$default$2()
static int	$lessinit$greater$default$3()
static scala.concurrent.duration.Duration	$lessinit$greater$default$4()
static scala.Function0<BlockingQueue<Runnable>>	$lessinit$greater$default$5()
static RejectedExecutionHandler	$lessinit$greater$default$6()
static boolean	$lessinit$greater$default$7()
boolean	allowCorePoolTimeout()
static ThreadPoolConfig	apply(boolean allowCorePoolTimeout, int corePoolSize, int maxPoolSize, scala.concurrent.duration.Duration threadTimeout, scala.Function0<BlockingQueue<Runnable>> queueFactory, RejectedExecutionHandler rejectionPolicy, boolean isVirtualized)	INTERNAL API
static boolean	apply$default$1()
static int	apply$default$2()
static int	apply$default$3()
static scala.concurrent.duration.Duration	apply$default$4()
static scala.Function0<BlockingQueue<Runnable>>	apply$default$5()
static RejectedExecutionHandler	apply$default$6()
static boolean	apply$default$7()
static scala.Function0<BlockingQueue<Runnable>>	arrayBlockingQueue(int capacity, boolean fair)
boolean	canEqual(Object x$1)
ThreadPoolConfig	copy(boolean allowCorePoolTimeout, int corePoolSize, int maxPoolSize, scala.concurrent.duration.Duration threadTimeout, scala.Function0<BlockingQueue<Runnable>> queueFactory, RejectedExecutionHandler rejectionPolicy, boolean isVirtualized)
boolean	copy$default$1()
int	copy$default$2()
int	copy$default$3()
scala.concurrent.duration.Duration	copy$default$4()
scala.Function0<BlockingQueue<Runnable>>	copy$default$5()
RejectedExecutionHandler	copy$default$6()
boolean	copy$default$7()
int	corePoolSize()
static boolean	defaultAllowCoreThreadTimeout()
static int	defaultCorePoolSize()
static int	defaultMaxPoolSize()
static RejectedExecutionHandler	defaultRejectionPolicy()
static scala.concurrent.duration.Duration	defaultTimeout()
boolean	equals(Object x$1)
int	hashCode()
boolean	isVirtualized()
static scala.Function0<BlockingQueue<Runnable>>	linkedBlockingQueue()
static scala.Function0<BlockingQueue<Runnable>>	linkedBlockingQueue(int capacity)
int	maxPoolSize()
int	productArity()
Object	productElement(int x$1)
String	productElementName(int x$1)
scala.collection.Iterator<Object>	productIterator()
String	productPrefix()
scala.Function0<BlockingQueue<Runnable>>	queueFactory()
RejectedExecutionHandler	rejectionPolicy()
static scala.Function0<BlockingQueue<Runnable>>	reusableQueue(BlockingQueue<Runnable> queue)
static scala.Function0<BlockingQueue<Runnable>>	reusableQueue(scala.Function0<BlockingQueue<Runnable>> queueFactory)
static int	scaledPoolSize(int floor, double multiplier, int ceiling)
static scala.Function0<BlockingQueue<Runnable>>	synchronousQueue(boolean fair)
scala.concurrent.duration.Duration	threadTimeout()
String	toString()
static scala.Option<scala.Tuple7<Object,Object,Object,scala.concurrent.duration.Duration,scala.Function0<BlockingQueue<Runnable>>,RejectedExecutionHandler,Object>>	unapply(ThreadPoolConfig x$0)

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productElementNames

Constructor Details

ThreadPoolConfig

public ThreadPoolConfig(boolean allowCorePoolTimeout,
 int corePoolSize,
 int maxPoolSize,
 scala.concurrent.duration.Duration threadTimeout,
 scala.Function0<BlockingQueue<Runnable>> queueFactory,
 RejectedExecutionHandler rejectionPolicy,
 boolean isVirtualized)

Method Details

$lessinit$greater$default$1

public static boolean $lessinit$greater$default$1()

INTERNAL API

Configuration object for ThreadPoolExecutor

$lessinit$greater$default$2

public static int $lessinit$greater$default$2()

$lessinit$greater$default$3

public static int $lessinit$greater$default$3()

$lessinit$greater$default$4

public static scala.concurrent.duration.Duration $lessinit$greater$default$4()

$lessinit$greater$default$5

public static scala.Function0<BlockingQueue<Runnable>> $lessinit$greater$default$5()

$lessinit$greater$default$6

public static RejectedExecutionHandler $lessinit$greater$default$6()

$lessinit$greater$default$7

public static boolean $lessinit$greater$default$7()

defaultAllowCoreThreadTimeout

public static boolean defaultAllowCoreThreadTimeout()

defaultCorePoolSize

public static int defaultCorePoolSize()

defaultMaxPoolSize

public static int defaultMaxPoolSize()

defaultTimeout

public static scala.concurrent.duration.Duration defaultTimeout()

defaultRejectionPolicy

public static RejectedExecutionHandler defaultRejectionPolicy()

scaledPoolSize

public static int scaledPoolSize(int floor,
 double multiplier,
 int ceiling)

arrayBlockingQueue

public static scala.Function0<BlockingQueue<Runnable>> arrayBlockingQueue(int capacity,
 boolean fair)

synchronousQueue

public static scala.Function0<BlockingQueue<Runnable>> synchronousQueue(boolean fair)

linkedBlockingQueue

public static scala.Function0<BlockingQueue<Runnable>> linkedBlockingQueue()

linkedBlockingQueue

public static scala.Function0<BlockingQueue<Runnable>> linkedBlockingQueue(int capacity)

reusableQueue

public static scala.Function0<BlockingQueue<Runnable>> reusableQueue(BlockingQueue<Runnable> queue)

reusableQueue

public static scala.Function0<BlockingQueue<Runnable>> reusableQueue(scala.Function0<BlockingQueue<Runnable>> queueFactory)

apply

public static ThreadPoolConfig apply(boolean allowCorePoolTimeout,
 int corePoolSize,
 int maxPoolSize,
 scala.concurrent.duration.Duration threadTimeout,
 scala.Function0<BlockingQueue<Runnable>> queueFactory,
 RejectedExecutionHandler rejectionPolicy,
 boolean isVirtualized)

INTERNAL API

Configuration object for ThreadPoolExecutor

apply$default$1

public static boolean apply$default$1()

apply$default$2

public static int apply$default$2()

apply$default$3

public static int apply$default$3()

apply$default$4

public static scala.concurrent.duration.Duration apply$default$4()

apply$default$5

public static scala.Function0<BlockingQueue<Runnable>> apply$default$5()

apply$default$6

public static RejectedExecutionHandler apply$default$6()

apply$default$7

public static boolean apply$default$7()

unapply

public static scala.Option<scala.Tuple7<Object,Object,Object,scala.concurrent.duration.Duration,scala.Function0<BlockingQueue<Runnable>>,RejectedExecutionHandler,Object>> unapply(ThreadPoolConfig x$0)

allowCorePoolTimeout

public boolean allowCorePoolTimeout()

corePoolSize

public int corePoolSize()

maxPoolSize

public int maxPoolSize()

threadTimeout

public scala.concurrent.duration.Duration threadTimeout()

queueFactory

public scala.Function0<BlockingQueue<Runnable>> queueFactory()

rejectionPolicy

public RejectedExecutionHandler rejectionPolicy()

isVirtualized

public boolean isVirtualized()

copy

public ThreadPoolConfig copy(boolean allowCorePoolTimeout,
 int corePoolSize,
 int maxPoolSize,
 scala.concurrent.duration.Duration threadTimeout,
 scala.Function0<BlockingQueue<Runnable>> queueFactory,
 RejectedExecutionHandler rejectionPolicy,
 boolean isVirtualized)

copy$default$1

public boolean copy$default$1()

copy$default$2

public int copy$default$2()

copy$default$3

public int copy$default$3()

copy$default$4

public scala.concurrent.duration.Duration copy$default$4()

copy$default$5

public scala.Function0<BlockingQueue<Runnable>> copy$default$5()

copy$default$6

public RejectedExecutionHandler copy$default$6()

copy$default$7

public boolean copy$default$7()

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