Package org.apache.pekko.dispatch

Class ThreadPoolConfig$

java.lang.Object

org.apache.pekko.dispatch.ThreadPoolConfig$

All Implemented Interfaces:

Serializable

public class ThreadPoolConfig$
extends Object
implements Serializable

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final ThreadPoolConfig$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
ThreadPoolConfig$()

Method Summary

Modifier and Type	Method	Description
boolean	$lessinit$greater$default$1()	INTERNAL API
int	$lessinit$greater$default$2()
int	$lessinit$greater$default$3()
scala.concurrent.duration.Duration	$lessinit$greater$default$4()
scala.Function0<BlockingQueue<Runnable>>	$lessinit$greater$default$5()
RejectedExecutionHandler	$lessinit$greater$default$6()
boolean	$lessinit$greater$default$7()
ThreadPoolConfig	apply(boolean allowCorePoolTimeout, int corePoolSize, int maxPoolSize, scala.concurrent.duration.Duration threadTimeout, scala.Function0<BlockingQueue<Runnable>> queueFactory, RejectedExecutionHandler rejectionPolicy, boolean isVirtualized)	INTERNAL API
boolean	apply$default$1()
int	apply$default$2()
int	apply$default$3()
scala.concurrent.duration.Duration	apply$default$4()
scala.Function0<BlockingQueue<Runnable>>	apply$default$5()
RejectedExecutionHandler	apply$default$6()
boolean	apply$default$7()
scala.Function0<BlockingQueue<Runnable>>	arrayBlockingQueue(int capacity, boolean fair)
boolean	defaultAllowCoreThreadTimeout()
int	defaultCorePoolSize()
int	defaultMaxPoolSize()
RejectedExecutionHandler	defaultRejectionPolicy()
scala.concurrent.duration.Duration	defaultTimeout()
scala.Function0<BlockingQueue<Runnable>>	linkedBlockingQueue()
scala.Function0<BlockingQueue<Runnable>>	linkedBlockingQueue(int capacity)
scala.Function0<BlockingQueue<Runnable>>	reusableQueue(BlockingQueue<Runnable> queue)
scala.Function0<BlockingQueue<Runnable>>	reusableQueue(scala.Function0<BlockingQueue<Runnable>> queueFactory)
int	scaledPoolSize(int floor, double multiplier, int ceiling)
scala.Function0<BlockingQueue<Runnable>>	synchronousQueue(boolean fair)
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, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final ThreadPoolConfig$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ThreadPoolConfig$

public ThreadPoolConfig$()

Method Details

$lessinit$greater$default$1

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

INTERNAL API

Configuration object for ThreadPoolExecutor

$lessinit$greater$default$2

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

$lessinit$greater$default$3

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

$lessinit$greater$default$4

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

$lessinit$greater$default$5

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

$lessinit$greater$default$6

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

$lessinit$greater$default$7

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

defaultAllowCoreThreadTimeout

public boolean defaultAllowCoreThreadTimeout()

defaultCorePoolSize

public int defaultCorePoolSize()

defaultMaxPoolSize

public int defaultMaxPoolSize()

defaultTimeout

public scala.concurrent.duration.Duration defaultTimeout()

defaultRejectionPolicy

public RejectedExecutionHandler defaultRejectionPolicy()

scaledPoolSize

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

arrayBlockingQueue

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

synchronousQueue

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

linkedBlockingQueue

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

linkedBlockingQueue

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

reusableQueue

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

reusableQueue

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

apply

public 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 boolean apply$default$1()

apply$default$2

public int apply$default$2()

apply$default$3

public int apply$default$3()

apply$default$4

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

apply$default$5

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

apply$default$6

public RejectedExecutionHandler apply$default$6()

apply$default$7

public boolean apply$default$7()

unapply

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