Package org.apache.pekko.dispatch

Class MonitorableThreadFactory

java.lang.Object

org.apache.pekko.dispatch.MonitorableThreadFactory

All Implemented Interfaces:

Serializable, ForkJoinPool.ForkJoinWorkerThreadFactory, ThreadFactory, scala.Equals, scala.Product

public final class MonitorableThreadFactory
extends Object
implements ThreadFactory, ForkJoinPool.ForkJoinWorkerThreadFactory, scala.Product, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
MonitorableThreadFactory(String name, boolean daemonic, scala.Option<ClassLoader> contextClassLoader, Thread.UncaughtExceptionHandler exceptionHandler, AtomicLong counter)

Method Summary

Modifier and Type	Method	Description
static Thread.UncaughtExceptionHandler	$lessinit$greater$default$4()
static AtomicLong	$lessinit$greater$default$5()
static MonitorableThreadFactory	apply(String name, boolean daemonic, scala.Option<ClassLoader> contextClassLoader, Thread.UncaughtExceptionHandler exceptionHandler, AtomicLong counter)
static Thread.UncaughtExceptionHandler	apply$default$4()
static AtomicLong	apply$default$5()
boolean	canEqual(Object x$1)
scala.Option<ClassLoader>	contextClassLoader()
MonitorableThreadFactory	copy(String name, boolean daemonic, scala.Option<ClassLoader> contextClassLoader, Thread.UncaughtExceptionHandler exceptionHandler, AtomicLong counter)
String	copy$default$1()
boolean	copy$default$2()
scala.Option<ClassLoader>	copy$default$3()
Thread.UncaughtExceptionHandler	copy$default$4()
AtomicLong	copy$default$5()
protected AtomicLong	counter()
AtomicLong	counter$access$4()
boolean	daemonic()
static Thread.UncaughtExceptionHandler	doNothing()
boolean	equals(Object x$1)
Thread.UncaughtExceptionHandler	exceptionHandler()
int	hashCode()
String	name()
Thread	newThread(Runnable runnable)
ForkJoinWorkerThread	newThread(ForkJoinPool pool)
int	productArity()
Object	productElement(int x$1)
String	productElementName(int x$1)
scala.collection.Iterator<Object>	productIterator()
String	productPrefix()
String	toString()
static scala.Option<scala.Tuple5<String,Object,scala.Option<ClassLoader>,Thread.UncaughtExceptionHandler,AtomicLong>>	unapply(MonitorableThreadFactory x$0)
protected <T extends Thread> T	wire(T t)
MonitorableThreadFactory	withName(String newName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productElementNames

Constructor Details

MonitorableThreadFactory

public MonitorableThreadFactory(String name,
 boolean daemonic,
 scala.Option<ClassLoader> contextClassLoader,
 Thread.UncaughtExceptionHandler exceptionHandler,
 AtomicLong counter)

Method Details

$lessinit$greater$default$4

public static Thread.UncaughtExceptionHandler $lessinit$greater$default$4()

$lessinit$greater$default$5

public static AtomicLong $lessinit$greater$default$5()

doNothing

public static Thread.UncaughtExceptionHandler doNothing()

apply

public static MonitorableThreadFactory apply(String name,
 boolean daemonic,
 scala.Option<ClassLoader> contextClassLoader,
 Thread.UncaughtExceptionHandler exceptionHandler,
 AtomicLong counter)

apply$default$4

public static Thread.UncaughtExceptionHandler apply$default$4()

apply$default$5

public static AtomicLong apply$default$5()

unapply

public static scala.Option<scala.Tuple5<String,Object,scala.Option<ClassLoader>,Thread.UncaughtExceptionHandler,AtomicLong>> unapply(MonitorableThreadFactory x$0)

counter$access$4

public AtomicLong counter$access$4()

name

public String name()

daemonic

public boolean daemonic()

contextClassLoader

public scala.Option<ClassLoader> contextClassLoader()

exceptionHandler

public Thread.UncaughtExceptionHandler exceptionHandler()

counter

protected AtomicLong counter()

newThread

public ForkJoinWorkerThread newThread(ForkJoinPool pool)

Specified by:

newThread in interface ForkJoinPool.ForkJoinWorkerThreadFactory

newThread

public Thread newThread(Runnable runnable)

Specified by:

newThread in interface ThreadFactory

withName

public MonitorableThreadFactory withName(String newName)

wire

protected <T extends Thread> T wire(T t)

copy

public MonitorableThreadFactory copy(String name,
 boolean daemonic,
 scala.Option<ClassLoader> contextClassLoader,
 Thread.UncaughtExceptionHandler exceptionHandler,
 AtomicLong counter)

copy$default$1

public String copy$default$1()

copy$default$2

public boolean copy$default$2()

copy$default$3

public scala.Option<ClassLoader> copy$default$3()

copy$default$4

public Thread.UncaughtExceptionHandler copy$default$4()

copy$default$5

public AtomicLong copy$default$5()

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